|
|
func (v *Server) transport(ctx context.Context, reader io.Reader, writer io.Writer, dest net.Destination, dispatcher dispatcher.Interface) error {
|
|
func (v *Server) transport(ctx context.Context, reader io.Reader, writer io.Writer, dest net.Destination, dispatcher dispatcher.Interface) error {
|
|
|
ctx, timer := signal.CancelAfterInactivity(ctx, timeout)
|
|
ctx, timer := signal.CancelAfterInactivity(ctx, timeout)
|