Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type HijackedIOStreamer ¶
type HijackedIOStreamer struct {
InputStream *streams.In
OutputStream *streams.Out
ErrorStream *streams.Out
Resp types.HijackedResponse
Tty bool
}
func (*HijackedIOStreamer) Stream ¶
func (h *HijackedIOStreamer) Stream(ctx context.Context) error
FIXME: if the output stream ends first, this method will leak the input streaming goroutine until one last read() operation returns. In the context of this Kotlin library, the stdin stream will be closed by the Kotlin side as soon as the container exits if the stdin stream is an Okio-backed input stream, so the goroutine will exit once that happens. If the stdin stream is /dev/stdin, then the goroutine will exit after consuming one more read operation, which may not happen for quite some time. There doesn't seem to be an easy way to avoid this.
type Reader ¶
type Reader struct {
// contains filtered or unexported fields
}
Reader is a Reader with progress bar.
func NewProgressReader ¶
func NewProgressReader(in io.ReadCloser, out progress.Output, size int64, id, action string) *Reader
NewProgressReader creates a new ProgressReader.
Source Files
Click to show internal directories.
Click to hide internal directories.