bigtype.rs

type T = futures::Join<
    futures::AndThen<
        futures::future::FromErr<
            std::boxed::Box<
                futures::Future<
                    Error = mercurial::Error,
                    Item = mercurial::changeset::RevlogChangeset,
                >
                    + std::marker::Send
                    + 'static,
            >,
            Error,
        >,
        futures::MapErr<
            std::boxed::Box<
                futures::Future<Error = blobrepo::Error, Item = ()> + std::marker::Send + 'static,
            >,
            fn(blobrepo::Error) -> Error, /* {<blobrepo::Error as std::convert::Into<Error>>::into} */
        >,
        Closure, /* [closure@scm/mononoke/cmds/blobimport.rs:243:23: 247:14 csid:mercurial_types::NodeHash, blobstore:std::sync::Arc<blobstore::Blobstore<GetBlob=std::boxed::Box<futures::Future<Error=Error, Item=std::option::Option<std::vec::Vec<u8>>> + std::marker::Send + 'static>, ValueOut=std::vec::Vec<u8>, Key=std::string::String, Error=Error, ValueIn=bytes::Bytes, PutBlob=std::boxed::Box<futures::Future<Error=Error, Item=()> + std::marker::Send + 'static>> + std::marker::Sync + 'static>] */
    >,
    futures::MapErr<
        futures::AndThen<
            futures::future::FromErr<
                futures::Join<
                    std::boxed::Box<
                        futures::Future<
                            Error = mercurial::Error,
                            Item = mercurial::changeset::RevlogChangeset,
                        >
                            + std::marker::Send
                            + 'static,
                    >,
                    futures::FutureResult<mercurial::revlog::Entry, mercurial::Error>,
                >,
                Error,
            >,
            futures::AndThen<
                futures::future::FromErr<
                    futures::FutureResult<mercurial_types::BlobNode, mercurial::Error>,
                    Error,
                >,
                futures::Join<
                    impl std::marker::Send + futures::Future,
                    futures::Flatten<
                        futures::FutureResult<
                            futures::stream::ForEach<
                                futures::stream::Flatten<
                                    futures::stream::Map<
                                        futures::stream::MapErr<
                                            std::boxed::Box<
                                                futures::Stream<
                                                    Item = std::boxed::Box<
                                                        mercurial_types::Entry<
                                                            Error = mercurial::Error,
                                                        >
                                                            + std::marker::Sync
                                                            + 'static,
                                                    >,
                                                    Error = mercurial::Error,
                                                >
                                                    + std::marker::Send
                                                    + 'static,
                                            >,
                                            fn(mercurial::Error) -> Error, /* {<Error as std::convert::From<mercurial::Error>>::from} */
                                        >,
                                        Closure, /* [closure@scm/mononoke/cmds/blobimport.rs:281:41: 287:42 revlog_repo:mercurial::RevlogRepo, linkrev:mercurial::revlog::RevIdx] */
                                    >,
                                >,
                                Closure, /* [closure@scm/mononoke/cmds/blobimport.rs:291:41: 291:99 blobstore:std::sync::Arc<blobstore::Blobstore<GetBlob=std::boxed::Box<futures::Future<Error=Error, Item=std::option::Option<std::vec::Vec<u8>>> + std::marker::Send + 'static>, ValueOut=std::vec::Vec<u8>, Key=std::string::String, Error=Error, ValueIn=bytes::Bytes, PutBlob=std::boxed::Box<futures::Future<Error=Error, Item=()> + std::marker::Send + 'static>> + std::marker::Sync + 'static>] */
                                impl std::marker::Send + futures::Future,
                            >,
                            Error,
                        >,
                    >,
                >,
                Closure, /* [closure@scm/mononoke/cmds/blobimport.rs:263:31: 299:22 blobstore:std::sync::Arc<blobstore::Blobstore<GetBlob=std::boxed::Box<futures::Future<Error=Error, Item=std::option::Option<std::vec::Vec<u8>>> + std::marker::Send + 'static>, ValueOut=std::vec::Vec<u8>, Key=std::string::String, Error=Error, ValueIn=bytes::Bytes, PutBlob=std::boxed::Box<futures::Future<Error=Error, Item=()> + std::marker::Send + 'static>> + std::marker::Sync + 'static>, mfid:mercurial_types::NodeHash, revlog_repo:mercurial::RevlogRepo, linkrev:mercurial::revlog::RevIdx] */
            >,
            Closure, /* [closure@scm/mononoke/cmds/blobimport.rs:255:23: 300:14 revlog_repo:mercurial::RevlogRepo, blobstore:std::sync::Arc<blobstore::Blobstore<GetBlob=std::boxed::Box<futures::Future<Error=Error, Item=std::option::Option<std::vec::Vec<u8>>> + std::marker::Send + 'static>, ValueOut=std::vec::Vec<u8>, Key=std::string::String, Error=Error, ValueIn=bytes::Bytes, PutBlob=std::boxed::Box<futures::Future<Error=Error, Item=()> + std::marker::Send + 'static>> + std::marker::Sync + 'static>] */
        >,
        Closure, /* [closure@scm/mononoke/cmds/blobimport.rs:301:22: 303:14 csid:mercurial_types::NodeHash] */
    >,
>;