Package java.nio

Examples of java.nio.CharBuffer.rewind()


        InputStream in = conn.getInputStream();
        CharBuffer cbuf = CharBuffer.allocate(length);
        Reader reader = new InputStreamReader(in);
        reader.read(cbuf);
        in.close();
        cbuf.rewind();

        return cbuf;
    }

    @SuppressWarnings("unchecked")
View Full Code Here


      @Override
      public HttpRequest run() throws IOException {
        final CharBuffer buffer = CharBuffer.allocate(bufferSize);
        int read;
        while ((read = reader.read(buffer)) != -1) {
          buffer.rewind();
          appendable.append(buffer, 0, read);
          buffer.rewind();
        }
        return HttpRequest.this;
      }
View Full Code Here

        final CharBuffer buffer = CharBuffer.allocate(bufferSize);
        int read;
        while ((read = reader.read(buffer)) != -1) {
          buffer.rewind();
          appendable.append(buffer, 0, read);
          buffer.rewind();
        }
        return HttpRequest.this;
      }
    }.call();
  }
View Full Code Here

                    byteBuffer.limit(6);
                }

                buffer.put(0, c);

                buffer.rewind();
                byteBuffer.rewind();
                encoder.encode(buffer, byteBuffer, true);

                byteBuffer.flip();
View Full Code Here

            final StringBuilder sb = new StringBuilder(1024);
            final CharBuffer cbuf = CharBuffer.allocate(1024);
            try {
                final Reader rdr = ((Clob) value).getCharacterStream();
                while (rdr.read(cbuf) >= 0) {
                    cbuf.rewind();
                    sb.append(cbuf);
                    cbuf.rewind();
                }
            } catch (IOException e) {
                throw new ConversionException("Error reading from clob", e);
View Full Code Here

            try {
                final Reader rdr = ((Clob) value).getCharacterStream();
                while (rdr.read(cbuf) >= 0) {
                    cbuf.rewind();
                    sb.append(cbuf);
                    cbuf.rewind();
                }
            } catch (IOException e) {
                throw new ConversionException("Error reading from clob", e);
            } catch (SQLException e) {
                throw new ConversionException("Error reading from clob", e);
View Full Code Here

    StringAppender sb = new StringAppender(request.getContentLength());
    CharBuffer buffer = CharBuffer.allocate(10);

    int read;
    while ((read = reader.read(buffer)) > 0) {
      buffer.rewind();
      for (; read > 0; read--) {
        sb.append(buffer.get());
      }
      buffer.rewind();
    }
View Full Code Here

    while ((read = reader.read(buffer)) > 0) {
      buffer.rewind();
      for (; read > 0; read--) {
        sb.append(buffer.get());
      }
      buffer.rewind();
    }

    Message msg = createCommandMessage(session, sb.toString());
    if (msg != null) {
      try {
View Full Code Here

    StringAppender sb = new StringAppender(httpServletRequest.getContentLength());
    CharBuffer buffer = CharBuffer.allocate(10);

    int read;
    while ((read = reader.read(buffer)) > 0) {
      buffer.rewind();
      for (; read > 0; read--) {
        sb.append(buffer.get());
      }
      buffer.rewind();
    }
View Full Code Here

    while ((read = reader.read(buffer)) > 0) {
      buffer.rewind();
      for (; read > 0; read--) {
        sb.append(buffer.get());
      }
      buffer.rewind();
    }

    Message m = createCommandMessage(session, sb.toString());
    if (m != null) {
      try {
View Full Code Here

TOP
Copyright © 2018 www.massapi.com. 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.