(SerializingExecutor executor, TransportExceptionHandler exceptionHandler,
int maxQueuedControlFrames)
| 63 | private int queuedControlFrames; |
| 64 | |
| 65 | private AsyncSink(SerializingExecutor executor, TransportExceptionHandler exceptionHandler, |
| 66 | int maxQueuedControlFrames) { |
| 67 | this.serializingExecutor = checkNotNull(executor, "executor"); |
| 68 | this.transportExceptionHandler = checkNotNull(exceptionHandler, "exceptionHandler"); |
| 69 | this.maxQueuedControlFrames = maxQueuedControlFrames; |
| 70 | } |
| 71 | |
| 72 | /** |
| 73 | * {@code maxQueuedControlFrames} is only effective for frames written with |
nothing calls this directly
no test coverage detected