X-Git-Url: https://ruderich.org/simon/gitweb/?p=safcm%2Fsafcm.git;a=blobdiff_plain;f=rpc%2Fconn.go;h=03b748545f12c1c588acb24bac2761e0b439b25c;hp=9786941c7e808966a9a76841bfd6e03981f81ba6;hb=9d0d090fc1d683accc8bd1b354425c23cbe9fb6a;hpb=8a3f6af248e28ea7efc1bf89751a597d28834942 diff --git a/rpc/conn.go b/rpc/conn.go index 9786941..03b7485 100644 --- a/rpc/conn.go +++ b/rpc/conn.go @@ -124,9 +124,14 @@ func (c *Conn) wait() error { } // Kill forcefully terminates the connection. It's safe to call Kill (and -// Wait) multiple times. +// Wait) multiple times. Calling it before Dial*() was called will only close +// the Events channel. func (c *Conn) Kill() error { if c.cmd == nil { + if c.events != nil { + close(c.events) + c.events = nil + } return fmt.Errorf("Dial*() not called or already terminated") }