@Test public void aClosedSocketSavesItsDisconnect() throws IOException { theChannelIsClosedByException(); endPoint.poll(); verify(mockSessionContexts).onDisconnect(anyLong()); verifyDisconnected(); }
abstract int poll();
ReceiverEndPoint { abstract int poll(); }
ReceiverEndPoint { abstract int poll(); ReceiverEndPoint(
        final GatewayPublication publication,
        final TcpChannel channel,
        final long connectionId,
        final int bufferSize,
        final ErrorHandler errorHandler,
        final Framer framer,
        final int libraryId); }
ReceiverEndPoint { abstract int poll(); ReceiverEndPoint(
        final GatewayPublication publication,
        final TcpChannel channel,
        final long connectionId,
        final int bufferSize,
        final ErrorHandler errorHandler,
        final Framer framer,
        final int libraryId); void libraryId(final int libraryId); int libraryId(); }
ReceiverEndPoint { abstract int poll(); ReceiverEndPoint(
        final GatewayPublication publication,
        final TcpChannel channel,
        final long connectionId,
        final int bufferSize,
        final ErrorHandler errorHandler,
        final Framer framer,
        final int libraryId); void libraryId(final int libraryId); int libraryId();  }