Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 3,513 for Sink (0.29 sec)

  1. android/guava/src/com/google/common/io/ByteSink.java

      protected ByteSink() {}
    
      /**
       * Returns a {@link CharSink} view of this {@code ByteSink} that writes characters to this sink as
       * bytes encoded with the given {@link Charset charset}.
       */
      public CharSink asCharSink(Charset charset) {
        return new AsCharSink(charset);
      }
    
      /**
       * Opens a new {@link OutputStream} for writing to this sink. This method returns a new,
       * independent stream each time it is called.
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Tue Feb 28 20:13:02 GMT 2023
    - 5.5K bytes
    - Viewed (0)
  2. okhttp/src/main/kotlin/okhttp3/MultipartBody.kt

            byteCount += contentLength
          } else {
            body.writeTo(sink)
          }
    
          sink.write(CRLF)
        }
    
        sink!!.write(DASHDASH)
        sink.write(boundaryByteString)
        sink.write(DASHDASH)
        sink.write(CRLF)
    
        if (countBytes) {
          byteCount += byteCountBuffer!!.size
          byteCountBuffer.clear()
        }
    
        return byteCount
      }
    
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 10.9K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/io/ByteSourceTest.java

        TestByteSink sink = new TestByteSink();
    
        assertFalse(sink.wasStreamOpened() || sink.wasStreamClosed());
    
        assertEquals(bytes.length, source.copyTo(sink));
        assertTrue(source.wasStreamOpened() && source.wasStreamClosed());
        assertTrue(sink.wasStreamOpened() && sink.wasStreamClosed());
    
        assertArrayEquals(bytes, sink.getBytes());
      }
    
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 16.9K bytes
    - Viewed (0)
  4. okhttp/src/main/kotlin/okhttp3/internal/http2/Huffman.kt

          while (accumulatorBitCount >= 8) {
            accumulatorBitCount -= 8
            sink.writeByte((accumulator shr accumulatorBitCount).toInt())
          }
        }
    
        if (accumulatorBitCount > 0) {
          accumulator = accumulator shl (8 - accumulatorBitCount)
          accumulator = accumulator or (0xffL ushr accumulatorBitCount)
          sink.writeByte(accumulator.toInt())
        }
      }
    
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 8.3K bytes
    - Viewed (0)
  5. guava-tests/test/com/google/common/io/CharSourceTest.java

        TestCharSink sink = new TestCharSink();
    
        assertFalse(sink.wasStreamOpened() || sink.wasStreamClosed());
    
        assertEquals(STRING.length(), source.copyTo(sink));
        assertTrue(source.wasStreamOpened() && source.wasStreamClosed());
        assertTrue(sink.wasStreamOpened() && sink.wasStreamClosed());
    
        assertEquals(STRING, sink.getString());
      }
    
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 13K bytes
    - Viewed (0)
  6. okhttp-testing-support/src/main/kotlin/okhttp3/okio/LoggingFilesystem.kt

      override fun delete(
        path: Path,
        mustExist: Boolean,
      ) {
        log("delete($path)")
    
        super.delete(path, mustExist)
      }
    
      override fun sink(
        path: Path,
        mustCreate: Boolean,
      ): Sink {
        log("sink($path)")
    
        return super.sink(path, mustCreate)
      }
    
      override fun source(file: Path): Source {
        log("source($file)")
    
        return super.source(file)
      }
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 1.7K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/hash/AbstractStreamingHasherTest.java

        Sink sink = new Sink(4);
        sink.putShort((short) 0x0201);
        HashCode unused = sink.hash();
        sink.assertInvariants(2);
        sink.assertBytes(new byte[] {1, 2, 0, 0}); // padded with zeros
      }
    
      public void testInt() {
        Sink sink = new Sink(4);
        sink.putInt(0x04030201);
        HashCode unused = sink.hash();
        sink.assertInvariants(4);
        sink.assertBytes(new byte[] {1, 2, 3, 4});
      }
    
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 8.5K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/io/CharSinkTest.java

        assertEquals("", sink.getString());
        sink.write(STRING);
    
        assertTrue(sink.wasStreamOpened() && sink.wasStreamClosed());
        assertEquals(STRING, sink.getString());
      }
    
      public void testWriteFrom_reader() throws IOException {
        StringReader reader = new StringReader(STRING);
        sink.writeFrom(reader);
    
        assertTrue(sink.wasStreamOpened() && sink.wasStreamClosed());
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 4K bytes
    - Viewed (0)
  9. okhttp/src/main/kotlin/okhttp3/RequestBody.kt

      /**
       * Returns the number of bytes that will be written to sink in a call to [writeTo],
       * or -1 if that count is unknown.
       */
      @Throws(IOException::class)
      open fun contentLength(): Long = commonContentLength()
    
      /** Writes the content of this request to [sink]. */
      @Throws(IOException::class)
      abstract fun writeTo(sink: BufferedSink)
    
      /**
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Thu Jan 25 14:41:37 GMT 2024
    - 9.6K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/hash/LittleEndianByteArray.java

       *
       * @param sink the output byte array
       * @param offset the offset into the array at which to start writing
       * @param value the value to write
       */
      static void store64(byte[] sink, int offset, long value) {
        // We don't want to assert in production code.
        assert offset >= 0 && offset + 8 <= sink.length;
        // Delegates to the fast (unsafe)version or the fallback.
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Thu Feb 22 17:40:56 GMT 2024
    - 9.7K bytes
    - Viewed (0)
Back to top