how to call recv with timeout on SUB socket?

[lunfardo314]

optional context for recv? Or use WithTimeout in

zmq4/socket.go

Line 121 in 91805d6

func (sck *socket) Recv() (Msg, error) {

?

[sbinet]

yeah, right now, this is only possible like so:

ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
defer cancel()
ch := make(chan error)
go func() {
    msg, err = sck.Recv()
    ch <- err
}()
select {
case <-ctx.Done():
case err := <- ch:
    // ...
}

I guess one could indeed wire in a ctx context.Context argument to the Socket.Recv and Socket.Send methods...