Package io.vertx.core.buffer

Examples of io.vertx.core.buffer.Buffer

228
229
230
231
232
233
234
235
236
237
    while (pos < input.length()) {
      int chunkSize = chunkSizes[chunkPos++];
      if (chunkPos == chunkSizes.length) chunkPos = 0;
      int end = pos + chunkSize;
      end = end <= input.length() ? end : input.length();
      Buffer sub = input.getBuffer(pos, end);
      parser.handle(sub);
      pos += chunkSize;
    }
  }
View Full Code Here
29
30
31
32
33
34
35
36
  @Override
  public void encodeToWire(Buffer buffer, JsonArray jsonArray) {
    String strJson = jsonArray.encode();
    byte[] encoded = strJson.getBytes(CharsetUtil.UTF_8);
    buffer.appendInt(encoded.length);
    Buffer buff = Buffer.buffer(encoded);
    buffer.appendBuffer(buff);
  }
View Full Code Here
29
30
31
32
33
34
35
36
  @Override
  public void encodeToWire(Buffer buffer, JsonObject jsonObject) {
    String strJson = jsonObject.encode();
    byte[] encoded = strJson.getBytes(CharsetUtil.UTF_8);
    buffer.appendInt(encoded.length);
    Buffer buff = Buffer.buffer(encoded);
    buffer.appendBuffer(buff);
  }
View Full Code Here
306
307
308
309
310
311
312
313
314
315
  @Override
  public Buffer writeToBuffer() {
    String encoded = encode();
    byte[] bytes = encoded.getBytes();
    Buffer buffer = Buffer.buffer(bytes.length + 4);
    buffer.appendInt(bytes.length);
    buffer.appendBytes(bytes);
    return buffer;
  }
View Full Code Here
97
98
99
100
101
102
103
104
105
106
107
    testPublish(false);
  }

  @Test
  public void testSendBuffer() {
    Buffer sent = TestUtils.randomBuffer(100);
    testSend(sent, (buffer) -> {
      assertEquals(sent, buffer);
      assertFalse(sent == buffer); // Make sure it's copied
    });
  }
View Full Code Here
106
107
108
109
110
111
112
113
114
115
116
    });
  }

  @Test
  public void testReplyBuffer() {
    Buffer sent = TestUtils.randomBuffer(100);
    testReply(sent, (bytes) -> {
      assertEquals(sent, bytes);
      assertFalse(sent == bytes); // Make sure it's copied
    });
  }
View Full Code Here
115
116
117
118
119
120
121
122
123
124
125
    });
  }

  @Test
  public void testPublishBuffer() {
    Buffer sent = TestUtils.randomBuffer(100);
    testPublish(sent, (buffer) -> {
      assertEquals(sent, buffer);
      assertFalse(sent == buffer); // Make sure it's copied
    });
  }
View Full Code Here
45
46
47
48
49
50
51
52
53
54
55
56
57
  //https://github.com/vert-x/vert.x/issues/561
  @Test
  public void testSetGetInt() throws Exception {
    final int size = 10;
    Buffer buffer = Buffer.buffer(size);
    for (int i = 0; i < size; i++) {
      buffer.setInt(i * 4, (i + 1) * 10);
    }
    for (int i = 0; i < size; i++) {
      assertEquals((i + 1) * 10, buffer.getInt(i * 4));
    }
  }
View Full Code Here
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
  @Test
  public void testAppendBuff() throws Exception {

    int bytesLen = 100;
    byte[] bytes = TestUtils.randomByteArray(bytesLen);
    Buffer toAppend = Buffer.buffer(bytes);

    Buffer b = Buffer.buffer();
    b.appendBuffer(toAppend);
    assertEquals(b.length(), bytes.length);

    assertTrue(TestUtils.byteArraysEqual(bytes, b.getBytes()));
    b.appendBuffer(toAppend);
    assertEquals(b.length(), 2 * bytes.length);

    assertNullPointerException(() -> b.appendBuffer(null));
  }
View Full Code Here
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
  public void testAppendBytes() throws Exception {

    int bytesLen = 100;
    byte[] bytes = TestUtils.randomByteArray(bytesLen);

    Buffer b = Buffer.buffer();
    b.appendBytes(bytes);
    assertEquals(b.length(), bytes.length);
    assertTrue(TestUtils.byteArraysEqual(bytes, b.getBytes()));

    b.appendBytes(bytes);
    assertEquals(b.length(), 2 * bytes.length);

    assertNullPointerException(() -> b.appendBytes(null));
  }
View Full Code Here
TOP

Related Classes of io.vertx.core.buffer.Buffer

  • com.englishtown.vertx.jersey.examples.resources.ChunkedResource
  • com.englishtown.vertx.jersey.impl.DefaultJerseyHandler
  • com.englishtown.vertx.jersey.impl.DefaultJerseyHandlerTest
  • com.englishtown.vertx.jersey.impl.VertxResponseWriter$VertxChunkedOutputStream
  • io.vertx.core.eventbus.impl.codecs.JsonArrayMessageCodec
  • io.vertx.core.eventbus.impl.codecs.JsonObjectMessageCodec
  • io.vertx.core.eventbus.impl.MessageImpl
  • io.vertx.core.file.impl.AsyncFileImpl
  • io.vertx.core.file.impl.FileSystemImpl
  • io.vertx.core.http.impl.HttpClientImpl$ClientHandler
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.