Add SessionReader and SessionWriter worker threads for session #198
@@ -12,8 +12,7 @@ public class Session {
|
|||||||
private final SessionId id;
|
private final SessionId id;
|
||||||
private final TransportLayer transport;
|
private final TransportLayer transport;
|
||||||
private final BlockingQueue<PrimitiveResponse> responseQueue;
|
private final BlockingQueue<PrimitiveResponse> responseQueue;
|
||||||
|
private static final int RESPOND_QUEUE_SIZE = 32;
|
||||||
private final int RESPOND_QUEUE_SIZE = 32;
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Creates a new Session with the given transport and event bus.
|
* Creates a new Session with the given transport and event bus.
|
||||||
|
|||||||
Reference in New Issue
Block a user