Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 529 for writers (0.09 sec)

  1. okhttp/src/main/kotlin/okhttp3/internal/ws/RealWebSocket.kt

          reader = null
    
          if (enqueuedClose && messageAndCloseQueue.isEmpty()) {
            // Close the writer on the writer's thread.
            val writerToClose = this.writer
            if (writerToClose != null) {
              this.writer = null
              taskQueue.execute("$name writer close", cancelable = false) {
                writerToClose.closeQuietly()
              }
            }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 01 14:21:25 UTC 2024
    - 22.1K bytes
    - Viewed (0)
  2. compat/maven-plugin-api/src/main/java/org/apache/maven/plugin/logging/SystemStreamLog.java

            StringWriter sWriter = new StringWriter();
            PrintWriter pWriter = new PrintWriter(sWriter);
    
            error.printStackTrace(pWriter);
    
            System.out.println("[" + prefix + "] " + sWriter.toString());
        }
    
        private void print(String prefix, CharSequence content, Throwable error) {
            StringWriter sWriter = new StringWriter();
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  3. compat/maven-toolchain-builder/src/main/java/org/apache/maven/toolchain/io/ToolchainsWriter.java

     */
    @Deprecated(since = "4.0.0")
    public interface ToolchainsWriter {
    
        /**
         * Writes the supplied toolchains to the specified character writer. The writer will be automatically closed before
         * the method returns.
         *
         * @param output The writer to serialize the toolchains to, must not be {@code null}.
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 1.8K bytes
    - Viewed (0)
  4. internal/s3select/json/record.go

    	}
    
    	name = strings.ReplaceAll(name, "*", "__ALL__")
    	r.KVS = append(r.KVS, jstream.KV{Key: name, Value: v})
    	return r, nil
    }
    
    // WriteCSV - encodes to CSV data.
    func (r *Record) WriteCSV(writer io.Writer, opts sql.WriteCSVOpts) error {
    	var csvRecord []string
    	for _, kv := range r.KVS {
    		var columnValue string
    		switch val := kv.Value.(type) {
    		case float64:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 5.3K bytes
    - Viewed (0)
  5. internal/s3select/simdj/record.go

    	return sql.SelectFmtSIMDJSON, r.object
    }
    
    // WriteJSON - encodes to JSON data.
    func (r *Record) WriteJSON(writer io.Writer) error {
    	o := r.object
    	elems, err := o.Parse(nil)
    	if err != nil {
    		return err
    	}
    	b, err := elems.MarshalJSON()
    	if err != nil {
    		return err
    	}
    	n, err := writer.Write(b)
    	if err != nil {
    		return err
    	}
    	if n != len(b) {
    		return io.ErrShortWrite
    	}
    	return nil
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 5.4K bytes
    - Viewed (0)
  6. internal/ringbuffer/README.md

    Regular Reads will block until data is available, but not wait for a full buffer. 
    Writes will block until there is space available and writes bigger than the buffer will wait for reads to make space.
    
    `TryRead` and `TryWrite` are still available for non-blocking reads and writes.
    
    To signify the end of the stream, close the ring buffer from the writer side with `rb.CloseWriter()`
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 2.1K bytes
    - Viewed (0)
  7. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt

          }
          if (associatedStreamId == 0) {
            writer.headers(outFinished, streamId, requestHeaders)
          } else {
            require(!client) { "client streams shouldn't have associated stream IDs" }
            // HTTP/2 has a PUSH_PROMISE frame.
            writer.pushPromise(associatedStreamId, streamId, requestHeaders)
          }
        }
    
        if (flushHeaders) {
          writer.flush()
        }
    
        return stream
      }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 32.6K bytes
    - Viewed (0)
  8. okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/DerAdapter.kt

      fun fromDer(byteString: ByteString): T {
        val buffer = Buffer().write(byteString)
        val reader = DerReader(buffer)
        return fromDer(reader)
      }
    
      /**
       * Writes [value] to this adapter, unless it is the default value and can be safely omitted.
       *
       * If this does write a value, it will write a tag and a length and a full value.
       */
      fun toDer(
        writer: DerWriter,
        value: T,
      )
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  9. guava/src/com/google/common/io/CharStreams.java

        }
      }
    
      /**
       * Returns a Writer that sends all output to the given {@link Appendable} target. Closing the
       * writer will close the target if it is {@link Closeable}, and flushing the writer will flush the
       * target if it is {@link java.io.Flushable}.
       *
       * @param target the object to which output will be sent
       * @return a new Writer object, unless target is a Writer, in which case the target is returned
       */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed May 17 14:35:11 UTC 2023
    - 10.9K bytes
    - Viewed (0)
  10. src/archive/tar/testdata/writer-big.tar

    Joe Tsai <******@****.***> 1503528984 -0700
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Aug 24 01:35:39 UTC 2017
    - 512 bytes
    - Viewed (0)
Back to top