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