1 // RPC primitives for safcm: basic connection implementation
3 // Copyright (C) 2021 Simon Ruderich
5 // This program is free software: you can redistribute it and/or modify
6 // it under the terms of the GNU General Public License as published by
7 // the Free Software Foundation, either version 3 of the License, or
8 // (at your option) any later version.
10 // This program is distributed in the hope that it will be useful,
11 // but WITHOUT ANY WARRANTY; without even the implied warranty of
12 // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
13 // GNU General Public License for more details.
15 // You should have received a copy of the GNU General Public License
16 // along with this program. If not, see <http://www.gnu.org/licenses/>.
30 func NewGobConn(r io.Reader, w io.Writer) *GobConn {
32 enc: gob.NewEncoder(w),
33 dec: gob.NewDecoder(r),
37 func (c *GobConn) Send(x Msg) error {
38 // & lets Encode send the interface itself and not a concrete type
39 // which is necessary to Decode as an interface
40 return c.enc.Encode(&x)
43 func (c *GobConn) Recv() (Msg, error) {
45 err := c.dec.Decode(&x)