sigStream.message.pipe(
          map(({ senderId, recipientId, msg }) => ({
            streamId: sigStream.id,
            senderId,
            recipientId,