Function create 

pub fn create<T: Record>(buffer_size: usize) -> (Source<T>, Sink<T>)

Creates a new Source/Sink pair with default configuration.

This is the primary entry point for creating streaming pipelines.

Example

use laminar_core::streaming;

let (source, sink) = streaming::create::<MyEvent>(1024);

// Push data
source.push(event)?;

// Consume data
let subscription = sink.subscribe();
while let Some(batch) = subscription.poll() {
    // Process batch
}