@Test public void testWrite() throws Exception { String host = "192.168.0.30"; int port = 6379; String queueName = "tom-test"; boolean overwrite = true; int chunkSize = 4; String testOutput = "aaaaabbbbbcccccdddddeeeeefffff"; byte[] bTestOutput = testOutput.getBytes(); try (RedisOutputStream ros = new RedisOutputStream(host, port, queueName, overwrite, chunkSize)) { ros.write(bTestOutput); } }
@Override public void write(int b) throws IOException { if (pos == buf.length) { finishChunk(false); } buf[pos++] = (byte) b; }
RedisOutputStream extends OutputStream { @Override public void write(int b) throws IOException { if (pos == buf.length) { finishChunk(false); } buf[pos++] = (byte) b; } }
RedisOutputStream extends OutputStream { @Override public void write(int b) throws IOException { if (pos == buf.length) { finishChunk(false); } buf[pos++] = (byte) b; } RedisOutputStream(String host, int port, String queueName);  RedisOutputStream(String host, int port, String queueName, boolean overwrite);  RedisOutputStream(String host, int port, String queueName, boolean overwrite, int chunkSize); }
RedisOutputStream extends OutputStream { @Override public void write(int b) throws IOException { if (pos == buf.length) { finishChunk(false); } buf[pos++] = (byte) b; } RedisOutputStream(String host, int port, String queueName);  RedisOutputStream(String host, int port, String queueName, boolean overwrite);  RedisOutputStream(String host, int port, String queueName, boolean overwrite, int chunkSize); @Override void write(int b); @Override void write(byte[] b, int off, int len); @Override void flush(); @Override void close(); }
RedisOutputStream extends OutputStream { @Override public void write(int b) throws IOException { if (pos == buf.length) { finishChunk(false); } buf[pos++] = (byte) b; } RedisOutputStream(String host, int port, String queueName);  RedisOutputStream(String host, int port, String queueName, boolean overwrite);  RedisOutputStream(String host, int port, String queueName, boolean overwrite, int chunkSize); @Override void write(int b); @Override void write(byte[] b, int off, int len); @Override void flush(); @Override void close();  }