PubSubRejectCallback: ((err: any) => void)