Skip to content

Commit 26fdc0b

Browse files
ikalachyBenniR6
authored andcommitted
feat: batch processing
1 parent 11e76c6 commit 26fdc0b

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

src/main/java/io/neonbee/internal/codec/RawBatchResultMessageCodec.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,7 @@ public RawBatchResultMessageCodec() {
2424
@Override
2525
public void encodeToWire(Buffer buffer, RawBatchResult result) {
2626
Buffer payload = result.buffer();
27-
if (result.hasBuffer() && payload != null) {
27+
if (result.hasBuffer()) {
2828
buffer.appendInt(payload.length());
2929
buffer.appendBuffer(payload);
3030
} else {

0 commit comments

Comments
 (0)