Struct LocalTransport 

pub struct LocalTransport { /* private fields */ }

In-process collaboration transport backed by a broadcast channel.

This is the phase 1 default transport. It keeps all collaboration local to the process while preserving the same CollaborationTransport trait contract that a future A2A-backed transport would implement.

Example

use adk_code::a2a_compat::{CollaborationTransport, LocalTransport};
use adk_code::{CollaborationEvent, CollaborationEventKind};

let transport = LocalTransport::new(128);
let mut rx = transport.subscribe();

transport.publish(CollaborationEvent::new(
    "c1", "topic", "agent", CollaborationEventKind::WorkPublished,
)).await.unwrap();

let event = rx.recv().await.unwrap();
assert_eq!(event.correlation_id, "c1");

Implementations

impl LocalTransport

pub fn new(capacity: usize) -> Self

Create a new local transport with the given channel capacity.

The capacity determines how many events can be buffered before slow subscribers start lagging. A reasonable default is 256.

Trait Implementations

impl CollaborationTransport for LocalTransport

fn publish<'life0, 'async_trait>( &'life0 self, event: CollaborationEvent, ) -> Pin<Box<dyn Future<Output = Result<(), ExecutionError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Publish a collaboration event to all subscribers.

fn subscribe(&self) -> Box<dyn CollaborationReceiver>

Create a new receiver for collaboration events.

impl Debug for LocalTransport

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for LocalTransport

fn default() -> Self

Returns the “default value” for a type.