Skip to content

Commit da329e5

Browse files
committed
Fix format
Signed-off-by: Max Lambrecht <[email protected]>
1 parent 0dd8cf3 commit da329e5

File tree

1 file changed

+12
-6
lines changed

1 file changed

+12
-6
lines changed

spiffe/src/workload_api/client.rs

Lines changed: 12 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -439,8 +439,10 @@ impl WorkloadApiClient {
439439
/// stream item fails to be received or parsed.
440440
pub async fn stream_x509_svids(
441441
&self,
442-
) -> Result<impl Stream<Item = Result<X509Svid, GrpcClientError>> + Send + 'static, GrpcClientError>
443-
{
442+
) -> Result<
443+
impl Stream<Item = Result<X509Svid, GrpcClientError>> + Send + 'static,
444+
GrpcClientError,
445+
> {
444446
let request = X509svidRequest::default();
445447

446448
let mut client = self.client.clone();
@@ -462,8 +464,10 @@ impl WorkloadApiClient {
462464
/// established or the initial request fails.
463465
pub async fn stream_x509_bundles(
464466
&self,
465-
) -> Result<impl Stream<Item = Result<X509BundleSet, GrpcClientError>> + Send + 'static, GrpcClientError>
466-
{
467+
) -> Result<
468+
impl Stream<Item = Result<X509BundleSet, GrpcClientError>> + Send + 'static,
469+
GrpcClientError,
470+
> {
467471
let request = X509BundlesRequest::default();
468472

469473
let mut client = self.client.clone();
@@ -485,8 +489,10 @@ impl WorkloadApiClient {
485489
/// established or the initial request fails.
486490
pub async fn stream_jwt_bundles(
487491
&self,
488-
) -> Result<impl Stream<Item = Result<JwtBundleSet, GrpcClientError>> + Send + 'static, GrpcClientError>
489-
{
492+
) -> Result<
493+
impl Stream<Item = Result<JwtBundleSet, GrpcClientError>> + Send + 'static,
494+
GrpcClientError,
495+
> {
490496
let request = JwtBundlesRequest::default();
491497

492498
let mut client = self.client.clone();

0 commit comments

Comments
 (0)