cyclon.p2p-rtc-comms/lib/ShuffleStateFactory.js

"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
var IncomingShuffleState_1 = require("./IncomingShuffleState");
var OutgoingShuffleState_1 = require("./OutgoingShuffleState");
var ShuffleStateFactory = /** @class */ (function () {
    function ShuffleStateFactory(logger, asyncExecService) {
        this.logger = logger;
        this.asyncExecService = asyncExecService;
    }
    /**
     * Create a new outgoing shuffle state
     *
     * @param localNode The local Cyclon node
     * @param destinationNodePointer The pointer to the destination node
     * @param shuffleSet The set of node pointers to send in the request
     * @returns {OutgoingShuffleState}
     */
    ShuffleStateFactory.prototype.createOutgoingShuffleState = function (localNode, destinationNodePointer, shuffleSet) {
        return new OutgoingShuffleState_1.OutgoingShuffleState(localNode, destinationNodePointer, shuffleSet, this.asyncExecService, this.logger);
    };
    /**
     * Create a new incoming shuffle state
     *
     * @param localNode The local Cyclon node
     * @param sourcePointer The source peer's node pointer
     * @returns {IncomingShuffleState}
     */
    ShuffleStateFactory.prototype.createIncomingShuffleState = function (localNode, sourcePointer) {
        return new IncomingShuffleState_1.IncomingShuffleState(localNode, sourcePointer, this.asyncExecService, this.logger);
    };
    return ShuffleStateFactory;
}());
exports.ShuffleStateFactory = ShuffleStateFactory;
//# sourceMappingURL=ShuffleStateFactory.js.map