NAME

At::Protocol::Firehose - AT Protocol Firehose Client

SYNOPSIS

my $fh = $at->firehose(sub ( $header, $body, $err ) {
    return warn $err if $err;
    say "Event type: " . $header->{t};
});

$fh->start();

DESCRIPTION

At::Protocol::Firehose handles the real-time streaming of events from an AT Protocol relay or PDS. It decodes the binary DAG-CBOR messages into Perl data structures.

Each message from the firehose consists of two parts:

1. Header: A map containing the message type (t) and optional operation (op).
2. Body: The actual event data, which varies by message type.

Methods

`new( at =` $at, callback => $cb, [ url => $url ] )>

Constructor. url defaults to the global Bluesky relay firehose.

`start()`

Starts the WebSocket connection. This is non-blocking and requires an event loop (like Mojo::IOLoop) to be running.

AUTHOR

Sanko Robinson <sanko@cpan.org>

LICENSE

To install At, copy and paste the appropriate command in to your terminal.

cpanm

cpanm At

CPAN shell

perl -MCPAN -e shell
install At

For more information on module installation, please visit the detailed CPAN module installation guide.

	Global
`s`	Focus search bar
`?`	Bring up this help dialog

	GitHub
`g` `p`	Go to pull requests
`g` `i`	go to github issues (only if github is preferred repository)

	POD
`g` `a`	Go to author
`g` `c`	Go to changes
`g` `i`	Go to issues
`g` `d`	Go to dist
`g` `r`	Go to repository/SCM
`g` `s`	Go to source
`g` `b`	Go to file browse

	Search terms
module: (e.g. module:Plugin)
distribution: (e.g. distribution:Dancer auth)
author: (e.g. author:SONGMU Redis)
version: (e.g. version:1.00)

NAME

SYNOPSIS

DESCRIPTION

Methods

new( at = $at, callback => $cb, [ url => $url ] )>

start()

SEE ALSO

AUTHOR

LICENSE

Module Install Instructions

`new( at =` $at, callback => $cb, [ url => $url ] )>

`start()`