photonrx's Introduction

PhotonRx

PhotonRxは、Photon Unity NetworkingをUniRxのObservableとして扱えるようにしたライブラリです。 Photonのコールバック群をObservableTriggerとして定義しています。

PhotonRx supports to Photon Unity Networking as Observable(UniRx).

導入方法 (How to install)

PhotonRx.unitypackageをプロジェクトにインポートしてください。 Photon Unity NetworkingとUniRxは含んでいないので、これらは自身でインポートする必要があります。

Include PhotonRx.unitypackage to your Unity project.
(PhotonRx dose NOT contain PUN and UniRx assets.)

使い方(How to use)

using System;
using UnityEngine;
using System.Collections;
using PhotonRx;
using UniRx;

public class SubscribeConnection : MonoBehaviour
{
    private void Start()
    {
        this.OnConnectedToPhotonAsObservable()
            .Subscribe(_ => Debug.Log("Success"));

        this.OnFailedToConnectToPhotonAsObservable()
            .Subscribe(_ => Debug.Log("Failure"));
    }
}

Task support

using UnityEngine;
using System.Threading.Tasks;
using PhotonRx;

public class TaskSample : MonoBehaviour
{
    async void Start()
    {
        PhotonNetwork.autoJoinLobby = true;

        var isConnected = await Connect();

        if (!isConnected) return;

        var isJoined = await JoinRoom();

        Debug.Log(isJoined);

    }

    private async Task<bool> Connect()
    {
        // Connect to server
        var connect = await PhotonTask.ConnectUsingSettings("v1");

        if (connect.IsFailure)
        {
            // Failure
            Debug.LogError(connect.ToFailure.Value);
        }

        return connect.IsSuccess;
    }

    private async Task<bool> JoinRoom()
    {
        // Join random room
        var randomJoined = await PhotonTask.JoinRandomRoom();

        // Success
        if (randomJoined.IsSuccess) return true;

        // Create new room
        var created = await PhotonTask.CreateRoom("test", null, null, null);

        if (!created.IsSuccess)
        {
            // Failure
            Debug.LogError(created.ToFailure.Value);
        }

        return created.IsSuccess;
    }
}