func New(timeout time.Duration, notifyCb CustodyNotify) *Custodian {
	c := &Custodian{
		timeout:  timeout,
		notifyCb: notifyCb,
		requests: make(map[string]*custody),
	}
	c.timer = time.NewTimer(time.Hour)
	c.timer.Stop()
	c.stopCh = make(chan struct{})
	go c.notifyRoutine()
	return c
}
// New creates a new Custodian.  Timeout specifies the timeout of the
// Custodian, notifyCb specifies the callback function that is called
// by the Custodian when a timeout expires.
New creates a new Custodian.  Timeout specifies the timeout of the
Custodian, notifyCb specifies the callback function that is called
by the Custodian when a timeout expires.
// New creates a new Custodian . Timeout specifies the timeout of the // Custodian notifyCb specifies the callback function that is called // by the Custodian when a timeout expires .
func New(timeout time.Duration, notifyCb CustodyNotify) *Custodian {
	c := &Custodian{
		timeout:  timeout,
		notifyCb: notifyCb,
		requests: make(map[string]*custody),
	}
	c.timer = time.NewTimer(time.Hour)
	c.timer.Stop()
	c.stopCh = make(chan struct{})
	go c.notifyRoutine()
	return c
}
func New ( timeout time . Duration , notifyCb CustodyNotify ) * Custodian { c := & Custodian { timeout : timeout , notifyCb : notifyCb , requests : make ( map [ string ] * custody ) , } c . timer = time . NewTimer ( time . Hour ) c . timer . Stop ( ) c . stopCh = make ( chan struct { } ) go c . notifyRoutine ( ) return c }
New creates a new Custodian.
New creates a new Custodian .