MySQLDoubleBinlogProtocolValue implements MySQLBinlogProtocolValue { @Override public Serializable read(final MySQLBinlogColumnDef columnDef, final MySQLPacketPayload payload) { return payload.getByteBuf().readDoubleLE(); }  @Override Serializable read(final MySQLBinlogColumnDef columnDef, final MySQLPacketPayload payload);  }
@Test public void assertRead() { when(payload.getByteBuf()).thenReturn(byteBuf); when(byteBuf.readDoubleLE()).thenReturn(1.1d); MySQLDoubleBinlogProtocolValue actual = new MySQLDoubleBinlogProtocolValue(); assertThat(actual.read(columnDef, payload), is(1.1d)); }