mirror of
https://github.com/pezkuwichain/pezkuwi-subxt.git
synced 2026-06-09 20:11:09 +00:00
Expose internal functions used by spawn_tasks (#3166)
This allows to build a custom version of `spawn_tasks` with less copy-paste required. Resolves https://github.com/paritytech/polkadot-sdk/issues/2110 --------- Co-authored-by: Bastian Köcher <git@kchr.de>
This commit is contained in:
@@ -0,0 +1,9 @@
|
||||
title: Expose internal functions used by `spawn_tasks`
|
||||
|
||||
doc:
|
||||
- audience: Node Dev
|
||||
description: |
|
||||
This allows to build a custom version of `spawn_tasks` with less copy-paste required
|
||||
|
||||
crates:
|
||||
- name: sc-service
|
||||
@@ -460,7 +460,7 @@ where
|
||||
spawn_handle.spawn(
|
||||
"on-transaction-imported",
|
||||
Some("transaction-pool"),
|
||||
transaction_notifications(
|
||||
propagate_transaction_notifications(
|
||||
transaction_pool.clone(),
|
||||
tx_handler_controller,
|
||||
telemetry.clone(),
|
||||
@@ -532,7 +532,8 @@ where
|
||||
Ok(rpc_handlers)
|
||||
}
|
||||
|
||||
async fn transaction_notifications<Block, ExPool>(
|
||||
/// Returns a future that forwards imported transactions to the transaction networking protocol.
|
||||
pub async fn propagate_transaction_notifications<Block, ExPool>(
|
||||
transaction_pool: Arc<ExPool>,
|
||||
tx_handler_controller: sc_network_transactions::TransactionsHandlerController<
|
||||
<Block as BlockT>::Hash,
|
||||
@@ -560,7 +561,8 @@ async fn transaction_notifications<Block, ExPool>(
|
||||
.await;
|
||||
}
|
||||
|
||||
fn init_telemetry<Block, Client, Network>(
|
||||
/// Initialize telemetry with provided configuration and return telemetry handle
|
||||
pub fn init_telemetry<Block, Client, Network>(
|
||||
config: &mut Configuration,
|
||||
network: Network,
|
||||
client: Arc<Client>,
|
||||
@@ -598,7 +600,8 @@ where
|
||||
Ok(telemetry.handle())
|
||||
}
|
||||
|
||||
fn gen_rpc_module<TBl, TBackend, TCl, TRpc, TExPool>(
|
||||
/// Generate RPC module using provided configuration
|
||||
pub fn gen_rpc_module<TBl, TBackend, TCl, TRpc, TExPool>(
|
||||
deny_unsafe: DenyUnsafe,
|
||||
spawn_handle: SpawnTaskHandle,
|
||||
client: Arc<TCl>,
|
||||
|
||||
@@ -368,7 +368,7 @@ mod waiting {
|
||||
}
|
||||
|
||||
/// Starts RPC servers.
|
||||
fn start_rpc_servers<R>(
|
||||
pub fn start_rpc_servers<R>(
|
||||
config: &Configuration,
|
||||
gen_rpc_module: R,
|
||||
rpc_id_provider: Option<Box<dyn RpcSubscriptionIdProvider>>,
|
||||
|
||||
Reference in New Issue
Block a user