@Override
    public AsynchronousByteChannel getAsynchronousChannel() {
        return new RedissonAsynchronousByteChannel();
    }
@Test
    public void testAsyncReadWrite() throws ExecutionException, InterruptedException {
        RBinaryStream stream = redisson.getBinaryStream("test");

        AsynchronousByteChannel channel = stream.getAsynchronousChannel();
        ByteBuffer bb = ByteBuffer.wrap(new byte[]{1, 2, 3, 4, 5, 6, 7});
        channel.write(bb).get();

        AsynchronousByteChannel channel2 = stream.getAsynchronousChannel();
        ByteBuffer b = ByteBuffer.allocate(7);
        channel2.read(b).get();

        b.flip();
        assertThat(b).isEqualByComparingTo(bb);
    }