Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for NoOpNewStreamHandler (0.28 sec)

  1. staging/src/k8s.io/apimachinery/pkg/util/httpstream/httpstream.go

    // the stream is rejected. After the reply frame has been sent, replySent is closed.
    type NewStreamHandler func(stream Stream, replySent <-chan struct{}) error
    
    // NoOpNewStreamHandler is a stream handler that accepts a new stream and
    // performs no other logic.
    func NoOpNewStreamHandler(stream Stream, replySent <-chan struct{}) error { return nil }
    
    // Dialer knows how to open a streaming connection to a server.
    type Dialer interface {
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 23 22:33:38 UTC 2023
    - 6.4K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apimachinery/pkg/util/httpstream/spdy/connection.go

    	spdyConn, err := spdystream.NewConnection(conn, false)
    	if err != nil {
    		defer conn.Close()
    		return nil, err
    	}
    
    	return newConnection(spdyConn, httpstream.NoOpNewStreamHandler, pingPeriod, spdyConn.Ping), nil
    }
    
    // NewServerConnection creates a new SPDY server connection. newStreamHandler
    // will be invoked when the server receives a newly created stream from the
    // client.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 01 15:04:07 UTC 2021
    - 6.7K bytes
    - Viewed (0)
Back to top