inmem_transport.go
func NewInmemTransportWithTimeout(addr ServerAddress, timeout time.Duration) (ServerAddress, *InmemTransport) {
	if string(addr) == "" {
		addr = NewInmemAddr()
	}
	trans := &InmemTransport{
		consumerCh: make(chan RPC, 16),
		localAddr:  addr,
		peers:      make(map[ServerAddress]*InmemTransport),
		timeout:    timeout,
	}
	return addr, trans
}
func NewInmemTransportWithTimeout(addr ServerAddress, timeout time.Duration) (ServerAddress, *InmemTransport) {
	if string(addr) == "" {
		addr = NewInmemAddr()
	}
	trans := &InmemTransport{
		consumerCh: make(chan RPC, 16),
		localAddr:  addr,
		peers:      make(map[ServerAddress]*InmemTransport),
		timeout:    timeout,
	}
	return addr, trans
}
func NewInmemTransportWithTimeout ( addr ServerAddress , timeout time . Duration ) ( ServerAddress , * InmemTransport ) { if string ( addr ) == " " { addr = NewInmemAddr ( ) } trans := & InmemTransport { consumerCh : make ( chan RPC , 16 ) , localAddr : addr , peers : make ( map [ ServerAddress ] * InmemTransport ) , timeout : timeout , } return addr , trans }
// NewInmemTransportWithTimeout is used to initialize a new transport and
// generates a random local address if none is specified. The given timeout
// will be used to decide how long to wait for a connected peer to process the
// RPCs that we're sending it. See also Connect() and Consumer().
NewInmemTransportWithTimeout is used to initialize a new transport and generates a random local address if none is specified . The given timeout will be used to decide how long to wait for a connected peer to process the RPCs that we re sending it . See also Connect () and Consumer () .