inner

package
v0.0.0-...-485e543 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 27, 2015 License: Apache-2.0 Imports: 2 Imported by: 0

Documentation

Overview

Package inner contains some methods needed to implement an interface for manatcp. It's not meant to be used by anyone using the pubsubch package

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MClient

type MClient struct {
	// This will be initialized with a buffer of 1. When writing a command this
	// will have a number written to it containing the number of messages which
	// should be read off the connection (equal to number of channels
	// subscribed/unsubscribed to in the command, each one gets a message)
	ReadCountCh chan int
}

MClient implements the manatcp Client interface

func (MClient) IsPush

func (mc MClient) IsPush(i interface{}) bool

IsPush implements the IsPush method for the manatcp Client interface

func (MClient) Read

func (mc MClient) Read(r *bufio.Reader) (interface{}, error, bool)

Read implements the Read method for the manatcp Client interface

func (MClient) Write

func (mc MClient) Write(w *bufio.Writer, i interface{}) (error, bool)

Write implements the Write method for the manatcp Client interface

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL