Browse Source

refactoring

master
Nikita Koksharov 4 years ago
parent
commit
3cb91649f9
  1. 4
      src/main/java/com/corundumstudio/socketio/MultiRoomBroadcastOperations.java
  2. 4
      src/main/java/com/corundumstudio/socketio/SingleRoomBroadcastOperations.java
  3. 3
      src/main/java/com/corundumstudio/socketio/listener/DataListener.java
  4. 3
      src/main/java/com/corundumstudio/socketio/protocol/Packet.java
  5. 25
      src/main/java/com/corundumstudio/socketio/transport/BaseTransport.java

4
src/main/java/com/corundumstudio/socketio/MultiRoomBroadcastOperations.java

@ -22,8 +22,8 @@ import java.util.HashSet;
import java.util.Set;
/**
* @Author: liangjiaqi
* @Date: 2020/8/8 6:02 PM
* author: liangjiaqi
* date: 2020/8/8 6:02 PM
*/
public class MultiRoomBroadcastOperations implements BroadcastOperations {

4
src/main/java/com/corundumstudio/socketio/SingleRoomBroadcastOperations.java

@ -26,8 +26,8 @@ import java.util.Arrays;
import java.util.Collection;
/**
* @Author: liangjiaqi
* @Date: 2020/8/8 6:08 PM
* Author: liangjiaqi
* Date: 2020/8/8 6:08 PM
*/
public class SingleRoomBroadcastOperations implements BroadcastOperations {
private final String namespace;

3
src/main/java/com/corundumstudio/socketio/listener/DataListener.java

@ -26,8 +26,7 @@ public interface DataListener<T> {
* @param client - receiver
* @param data - received object
* @param ackSender - ack request
*
* @throws Exception
*
*/
void onData(SocketIOClient client, T data, AckRequest ackSender) throws Exception;

3
src/main/java/com/corundumstudio/socketio/protocol/Packet.java

@ -81,6 +81,9 @@ public class Packet implements Serializable {
* Creates a copy of #{@link Packet} with new namespace set
* if it differs from current namespace.
* Otherwise, returns original object unchanged
*
* @param namespace
* @return packet
*/
public Packet withNsp(String namespace) {
if (this.nsp.equalsIgnoreCase(namespace)) {

25
src/main/java/com/corundumstudio/socketio/transport/BaseTransport.java

@ -1,25 +0,0 @@
/**
* Copyright (c) 2012-2019 Nikita Koksharov
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package com.corundumstudio.socketio.transport;
import io.netty.channel.ChannelInboundHandlerAdapter;
import com.corundumstudio.socketio.Disconnectable;
@Deprecated
public abstract class BaseTransport extends ChannelInboundHandlerAdapter implements Disconnectable {
}
Loading…
Cancel
Save