Module blocks 

Library of common blocks that are not tied to a specific technology.

Block Library

Functional/Apply-style Blocks

Block	Usage	WebAssembly?
Apply	Apply a function to each sample.	✅
ApplyIntoIter	Apply a function on each input sample to create an iterator and output its values.	✅
ApplyNM	Apply a function to each N input samples, producing M output samples.	✅
Combine	Apply a function to combine two streams into one.	✅
Filter	Apply a function, returning an Option to allow filtering samples.	✅
Sink	Apply a function to received samples.	✅
Source	Repeatedly apply a function to generate samples.	✅
Split	Apply a function to split a stream.	✅
FiniteSource	Repeatedly apply a function to generate samples, using Option values to allow termination.	✅

Streams

Block	Usage	WebAssembly?
StreamDeinterleaver	Stream Deinterleave	✅
StreamDuplicator	Stream Duplicator	✅

DSP blocks

Block	Usage	WebAssembly?
Fft	Compute an FFT.	✅
Fir	FIR filter and resampler.	✅
Iir	IIR filter.	✅
PfbArbResampler	Polyphase Arbitrary Rate Resampler	✅
PfbChannelizer	Polyphase Channelizer	✅
PfbSynthesizer	Polyphase Synthesizer	✅
XlatingFir	Xlating FIR filter and decimator.	✅

Misc

Block	Usage	WebAssembly?
Delay	Delays samples.	✅
Head	Copies only a given number of samples and stops.	✅
MovingAvg	Applies an exponential moving average over a window samples.	✅
NullSink	Drops samples.	✅
NullSource	Generates a stream of zeros.	✅
Selector	Forward the input stream with a given index to the output stream with a given index.	✅
TagDebug	Drop samples, printing tags.	✅
Throttle	Limit sample rate.	✅
VectorSink	Store received samples in vector.	✅
VectorSource	Stream samples from vector.	✅

Message Passing

Block	Usage	WebAssembly?
MessageAnnotator	Wrap every message in a DictStrPmt and add fixed additional fields, to facilitate multiplexing w/o losing the source association	✅
MessageApply	Apply a function to each message, emitting the result as a new message.	✅
MessageBurst	Output a given number of messages in one burst and terminate.	✅
MessageCopy	Forward messages.	✅
MessagePipe	Push received messages into a channel.	✅
MessageSink	Black hole for messages.	✅
MessageSource	Output the same message periodically.	✅

Performance Evaluation

Block	Usage	WebAssembly?	Feature
Copy	Copy input samples to the output.	✅

I/O

Block	Usage	WebAssembly?
BlobToUdp	Push blobs into a UDP socket.	❌
ChannelSource	Push samples through a channel into a stream connection.	✅
ChannelSink	Read samples from Flowgraph and send them into a channel	✅
FileSink	Write samples to a file.	❌
FileSource	Read samples from a file.	❌
TcpSource	Reads samples from a TCP socket.	❌
TcpSink	Push samples into a TCP socket.	❌
UdpSource	Reads samples from a UDP socket.	❌
WebsocketSink	Push samples in a WebSocket.	❌
WebsocketPmtSink	Push samples from Pmts a WebSocket.	❌
zeromq::PubSink	Push samples into ZeroMQ socket.	❌
zeromq::SubSource	Read samples from ZeroMQ socket.	❌

SDR Hardware

Block	Usage	Feature	WebAssembly?
seify::Sink	Transmit samples with a Seify device.	seify	❌
seify::Source	Receive samples from a Seify device.	seify	❌
seify::AsyncSink	Transmit samples with an async Seify device.	seify	✅
seify::AsyncSource	Receive samples from an async Seify device.	seify	✅

Hardware Acceleration

Block	Usage	WebAssembly?	Feature
Wgpu	Interface GPU w/ native API.	✅	wgpu

WASM-specific (target wasm32-unknown-unknown)

Block	Usage	WebAssembly?
WasmWsSink	Send samples via a WebSocket.	✅

Signal Sources

Block	Usage	WebAssembly?
SignalSource	Create signals (sin, cos, square).	✅

Audio (requires audio feature)

Block	Usage	WebAssembly?
audio::AudioSink	Audio sink.	❌
audio::AudioSource	Audio source.	❌
audio::FileSource	Read an audio file and output its samples.	❌
audio::WavSink	Writes samples to a WAV file	❌

Re-exports

pub use signal_source::FixedPointPhase;

pub use signal_source::SignalSource;

pub use signal_source::SignalSourceBuilder;

pub use xlating_fir::XlatingFir;

Modules

signal_source

SignalSource using Lookup Tables

xlating_fir

Frequency Xlating FIR

Structs

Apply

Apply a function to each sample.

ApplyIntoIter

Apply a function on each input sample to create an iterator and output its values.

ApplyNM

Apply a function to each N input samples, producing M output samples.

BlobToUdp

Push Blobs into a UDP socket.

ChannelSink

Get samples out of a Flowgraph into a channel.

ChannelSource

Push samples through a channel into a stream connection.

Combine

Apply a function to combine two streams into one.

Copy

Copy input samples to the output.

Delay

Delays samples.

Fft

Compute an FFT.

FileSink

Write samples to a file.

FileSource

Read samples from a file.

Filter

Apply a function, returning an Option to allow filtering samples.

FiniteSource

Repeatedly apply a function to generate samples, using Option values to allow termination.

Fir

FIR filter.

FirBuilder

Create a Fir filter.

Head

Copies only a given number of samples and stops.

Iir

IIR filter.

IirBuilder

Create an Iir filter with default stream buffers.

MessageAnnotator

Add fixed fields to messages.

MessageApply

This Block applies a callback function to incoming messages, emitting the result as a new message.

MessageBurst

Output a given number of messages in one burst and terminate.

MessageCopy

Forward messages.

MessagePipe

Push received messages into a channel.

MessageSink

Black hole for messages.

MessageSource

Output the same message periodically.

MessageSourceBuilder

Repeats a fixed message on an interval

MovingAvg

Reads chunks of size WIDTH and outputs an exponential moving average over a window of specified size.

NullSink

Drop samples.

NullSource

Generate a stream of zeroes.

PfbArbResampler

Polyphase arbitrary rate resampler.

PfbChannelizer

Polyphase channelizer.

PfbSynthesizer

Polyphase Synthesizer.

Selector

Forward the input stream with a given index to the output stream with a given index.

Sink

Apply a function to received samples.

Source

Repeatedly apply a function to generate samples.

Split

Apply a function to split a stream.

StreamDeinterleaver

Deinterleave one stream into num_channels output streams.

StreamDuplicator

Duplicate one input stream into N output streams.

TagDebug

Drop samples, printing tags.

TcpSink

Push samples into a TCP socket.

TcpSource

Read samples from a TCP socket.

Throttle

Limit sample rate.

UdpSource

Read samples from a UDP socket.

VectorSink

Store received samples in vector.

VectorSource

Stream samples from vector.

WebsocketPmtSink

Push Samples from PMTs in a WebSocket.

WebsocketSink

Push samples in a WebSocket.

WebsocketSinkBuilder

Build a WebsocketSink.

Enums

FftDirection

Fft direction.

SelectorDropPolicy

Drop Policy for Selector block

WebsocketSinkMode

Operation mode for WebsocketSink.