Package org.vertx.java.core.buffer

Examples of org.vertx.java.core.buffer.Buffer

128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
    }

    @Override
    public void render(final String filename, final Map<String, Object> context, final Handler<AsyncResult<Buffer>> next) {

        final Buffer buffer = new Buffer();

        try {
            engine.process(filename, toIContext(context), new Writer() {
                @Override
                public void write(char[] cbuf, int off, int len) throws IOException {
                    buffer.appendString(new String(cbuf, off, len));
                }

                @Override
                public void flush() throws IOException {}
View Full Code Here
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
    /**
     * Avoid using this method for constant reads, use it only for one time only reads from resources in the classpath
     */
    public static Buffer readResourceToBuffer(@NotNull Class<?> clazz, @NotNull String resource) {
        try {
            Buffer buffer = new Buffer(0);

            try (InputStream in = clazz.getResourceAsStream(resource)) {
                int read;
                byte[] data = new byte[4096];
                while ((read = in.read(data, 0, data.length)) != -1) {
                    if (read == data.length) {
                        buffer.appendBytes(data);
                    } else {
                        byte[] slice = new byte[read];
                        System.arraycopy(data, 0, slice, 0, slice.length);
                        buffer.appendBytes(slice);
                    }
                }
            }

            return buffer;
View Full Code Here
37
38
39
40
41
42
43
    public YokeTester(Yoke yoke) {
        this(yoke, false);
    }

    public void request(final String method, final String url, final Handler<Response> handler) {
        request(method, url, new CaseInsensitiveMultiMap(), new Buffer(0), handler);
    }
View Full Code Here
41
42
43
44
45
46
47
    public void request(final String method, final String url, final Handler<Response> handler) {
        request(method, url, new CaseInsensitiveMultiMap(), new Buffer(0), handler);
    }

    public void request(final String method, final String url, final MultiMap headers, final Handler<Response> handler) {
        request(method, url, headers, new Buffer(0), handler);
    }
View Full Code Here
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
    @Test
    public void testFavicon() {
        Yoke yoke = new Yoke(this);
        yoke.use(new com.jetdrone.vertx.yoke.middleware.Favicon());

        final Buffer icon = Utils.readResourceToBuffer(com.jetdrone.vertx.yoke.middleware.Favicon.class, "favicon.ico");

        new YokeTester(yoke).request("GET", "/favicon.ico", new Handler<Response>() {
            @Override
            public void handle(Response resp) {
                assertEquals(200, resp.getStatusCode());
                assertArrayEquals(icon.getBytes(), resp.body.getBytes());
                testComplete();
            }
        });
    }
View Full Code Here
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
                request.response().end();
            }
        }));

        Buffer body = new Buffer(json.encode());

        MultiMap headers = new CaseInsensitiveMultiMap();
        headers.add("content-type", "application/json");
        headers.add("content-length", Integer.toString(body.length()));

        new YokeTester(yoke).request("POST", "/search/2012-07-14T00:00:00Z/2013-07-14T00:00:00Z", headers, body, new Handler<Response>() {
            @Override
            public void handle(Response resp) {
                assertEquals(200, resp.getStatusCode());
View Full Code Here
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
                request.response().end();
            }
        });

        Buffer body = new Buffer(json.encode());

        MultiMap headers = new CaseInsensitiveMultiMap();
        headers.add("content-type", "application/json");
        headers.add("content-length", Integer.toString(body.length()));

        new YokeTester(yoke).request("POST", "/", headers, body, new Handler<Response>() {
            @Override
            public void handle(Response resp) {
                assertEquals(200, resp.getStatusCode());
View Full Code Here
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
                request.response().end();
            }
        });

        Buffer body = new Buffer(json.encode());

        MultiMap headers = new CaseInsensitiveMultiMap();
        headers.add("content-type", "application/json");
        headers.add("content-length", Integer.toString(body.length()));

        new YokeTester(yoke).request("POST", "/", headers, body, new Handler<Response>() {
            @Override
            public void handle(Response resp) {
                assertEquals(200, resp.getStatusCode());
View Full Code Here
21
22
23
24
25
26
27
28
29
30
31
32
33
34
        MultiMap headers = new CaseInsensitiveMultiMap();
        headers.add("content-type", "text/plain");
        headers.add("content-length", "1024");

        Buffer body = new Buffer(1024);

        for (int i=0; i < 1024; i++) {
            body.appendByte((byte) 'A');
        }

        new YokeTester(yoke).request("GET", "/", headers, body, new Handler<Response>() {
            @Override
            public void handle(Response resp) {
View Full Code Here
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
  /*
   * Happy Path. b1 and b2 are non-empty.
   */
  @Test
  public void testMergeBuffersB1AndB2NonEmpty() {   
    Buffer b1 = new Buffer();
    b1.appendString("b1");
   
    Buffer b2 = new Buffer();
    b2.appendString("b2");
   
    Buffer acc = RxSupport.mergeBuffers.call(b1, b2);
    Buffer expectedAcc = new Buffer("b1b2");
   
    assertEquals(expectedAcc, acc);
  }
View Full Code Here
TOP

Related Classes of org.vertx.java.core.buffer.Buffer

  • com.englishtown.vertx.cassandra.binarystore.impl.DefaultBinaryStoreWriter
  • com.englishtown.vertx.cassandra.binarystore.impl.DefaultFileReader
  • com.englishtown.vertx.CassandraBinaryStore
  • com.englishtown.vertx.CouchbasePersistor
  • com.englishtown.vertx.GridFSModule
  • com.englishtown.vertx.jersey.impl.DefaultJerseyHandler
  • com.englishtown.vertx.jersey.impl.VertxResponseWriter$VertxChunkedOutputStream
  • com.englishtown.vertx.jersey.impl.VertxResponseWriter$VertxOutputStream
  • com.google.collide.server.fe.WebFE
  • com.jetdrone.vertx.persona.Persona
    • 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.