Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
 package com.englishtown.vertx.solr.streams.impl;
 
Write the JSON to a buffer stream
public class BufferJsonWriteStream implements WriteStream<JsonObject> {
    private final WriteStream<Bufferstream;
    public BufferJsonWriteStream(WriteStream<Bufferstream) {
        this. = stream;
    }
    @Override
        .exceptionHandler(handler);
        return this;
    }
    @Override
    public WriteStream<JsonObjectwrite(JsonObject data) {
        .write(Buffer.buffer(data.encode()));
        return this;
    }
    @Override
    public WriteStream<JsonObjectsetWriteQueueMaxSize(int maxSize) {
        .setWriteQueueMaxSize(maxSize);
        return this;
    }
    @Override
    public boolean writeQueueFull() {
        return .writeQueueFull();
    }
    @Override
    public WriteStream<JsonObjectdrainHandler(Handler<Voidhandler) {
        .drainHandler(handler);
        return this;
    }
New to GrepCode? Check out our FAQ X