streammux

package module
Version: v0.1.0 Latest Latest
Warning

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

Go to latest
Published: May 23, 2019 License: MIT Imports: 1 Imported by: 35

README

go-stream-muxer - generalized stream multiplexing

Discourse posts

A test suite and interface you can use to implement a stream muxer.

go-stream-muxer is a common interface for stream muxers, with common tests. It wraps other stream muxers (like muxado, spdystream and yamux).

Godoc: https://godoc.org/github.com/libp2p/go-stream-muxer

Implementations

Badge

Include this badge in your readme if you make a new module that uses abstract-stream-muxer API.

Installation

go get -d github.com/libp2p/go-stream-muxer
cd $GOPATH/src/github.com/libp2p/go-stream-muxer
make deps

Client example

import (
  "net"
  "fmt"
  "io"
  "os"

  ymux "github.com/whyrusleeping/go-smux-yamux"
)

func dial() {
  nconn, _ := net.Dial("tcp", "localhost:1234")
  sconn, _ := ymux.DefaultTransport.NewConn(nconn, false) // false == client

  go func() {
    // no-op
    for {
      sconn.AcceptStream()
    }
  }()

  s1, _ := sconn.OpenStream()
  s1.Write([]byte("hello"))

  s2, _ := sconn.OpenStream()
  s2.Write([]byte("world"))

  length := 20
  buf2 := make([]byte, length)
  fmt.Printf("reading %d bytes from stream (echoed)\n", length)

  s1.Read(buf2)

  fmt.Printf("received %s as a response\n", string(buf2))

  s3, _ := sconn.OpenStream()
  io.Copy(s3, os.Stdin)
}

Server example

import (
  "net"
  "fmt"
  "io"

  smux "github.com/libp2p/go-stream-muxer"
  ymux "github.com/whyrusleeping/go-smux-yamux"
)

func listen() {
  tr := ymux.DefaultTransport
  l, _ := net.Listen("tcp", "localhost:1234")

  for {
    c, _ := l.Accept()

    fmt.Println("accepted connection")
    sc, _ := tr.NewConn(c, true)

    go func() {
      fmt.Println("serving connection")
      for {
        s, _ := sc.AcceptStream()
        echoStream(s)
      }
    }()
  }
}

func echoStream(s smux.Stream) {
  defer s.Close()

  fmt.Println("accepted stream")
  io.Copy(s, s) // echo everything
  fmt.Println("closing stream")
}

The last gx published version of this module was: 3.1.0: QmVtV1y2e8W4eQgzsP6qfSpCCZ6zWYE4m6NzJjB7iswwrT

Documentation

Index

Constants

This section is empty.

Variables

View Source
var ErrReset = core.ErrReset

Deprecated: use github.com/libp2p/go-libp2p-core/mux.ErrReset instead.

View Source
var NoOpHandler = core.NoopHandler

Deprecated: use github.com/libp2p/go-libp2p-core/mux.NoopHandler instead.

Functions

This section is empty.

Types

type Conn deprecated

type Conn = core.MuxedConn

Deprecated: use github.com/libp2p/go-libp2p-core/mux.MuxedConn instead.

type Stream deprecated

type Stream = core.MuxedStream

Deprecated: use github.com/libp2p/go-libp2p-core/mux.MuxedStream instead.

type Transport deprecated

type Transport = core.Multiplexer

Deprecated: use github.com/libp2p/go-libp2p-core/mux.Multiplexer instead.

Source Files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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