Function handler 

pub async fn handler(
    __arg0: State<State>,
    __arg1: Query<StartBlock>,
) -> Sse<impl Stream<Item = Result<Event, SubscriptionError>>>