q

Documentation

Overview

Package q contain non-blocking unlimited queue data structures.

Index

• func NewBytesQueue() (chan<- []byte, <-chan []byte)
• func NewStringQueue() (chan<- string, <-chan string)

Functions

func NewBytesQueue

func NewBytesQueue() (chan<- []byte, <-chan []byte)

NewBytesQueue creates a non blocking bytearray queue channel.

func NewStringQueue

func NewStringQueue() (chan<- string, <-chan string)

NewStringQueue creates a non blocking string queue channel.