上海虹口龙之梦项目
You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
 
 
 
 

156 lines
4.2 KiB

#if !BESTHTTP_DISABLE_SERVERSENT_EVENTS
using System;
using BestHTTP.Examples.Helpers;
using BestHTTP.ServerSentEvents;
using UnityEngine;
using UnityEngine.UI;
namespace BestHTTP.Examples.ServerSentEvents
{
public class SimpleSample : BestHTTP.Examples.Helpers.SampleBase
{
#pragma warning disable 0649
[Tooltip("The url of the resource to use.")]
[SerializeField]
private string _path = "/sse";
[SerializeField]
private ScrollRect _scrollRect;
[SerializeField]
private RectTransform _contentRoot;
[SerializeField]
private TextListItem _listItemPrefab;
[SerializeField]
private int _maxListItemEntries = 100;
[SerializeField]
private Button _startButton;
[SerializeField]
private Button _closeButton;
#pragma warning restore
private EventSource eventSource;
protected override void Start()
{
base.Start();
SetButtons(true, false);
}
void OnDestroy()
{
if (this.eventSource != null)
{
this.eventSource.Close();
this.eventSource = null;
}
}
public void OnStartButton()
{
GUIHelper.RemoveChildren(this._contentRoot, 0);
// Create the EventSource instance
this.eventSource = new EventSource(new Uri(base.sampleSelector.BaseURL + this._path));
// Subscribe to generic events
this.eventSource.OnOpen += OnOpen;
this.eventSource.OnClosed += OnClosed;
this.eventSource.OnError += OnError;
this.eventSource.OnStateChanged += this.OnStateChanged;
this.eventSource.OnMessage += OnMessage;
// Subscribe to an application specific event
this.eventSource.On("datetime", OnDateTime);
// Start to connect to the server
this.eventSource.Open();
AddText("Opening Server-Sent Events...");
SetButtons(false, true);
}
public void OnCloseButton()
{
SetButtons(false, false);
this.eventSource.Close();
}
private void OnOpen(EventSource eventSource)
{
AddText("Open");
}
private void OnClosed(EventSource eventSource)
{
AddText("Closed");
this.eventSource = null;
SetButtons(true, false);
}
private void OnError(EventSource eventSource, string error)
{
AddText(string.Format("Error: <color=red>{0}</color>", error));
}
private void OnStateChanged(EventSource eventSource, States oldState, States newState)
{
AddText(string.Format("State Changed {0} => {1}", oldState, newState));
}
private void OnMessage(EventSource eventSource, Message message)
{
AddText(string.Format("Message: <color=yellow>{0}</color>", message));
}
private void OnDateTime(EventSource eventSource, Message message)
{
DateTimeData dtData = BestHTTP.JSON.LitJson.JsonMapper.ToObject<DateTimeData>(message.Data);
AddText(string.Format("OnDateTime: <color=yellow>{0}</color>", dtData.ToString()));
}
private void SetButtons(bool start, bool close)
{
if (this._startButton != null)
this._startButton.interactable = start;
if (this._closeButton != null)
this._closeButton.interactable = close;
}
private void AddText(string text)
{
GUIHelper.AddText(this._listItemPrefab, this._contentRoot, text, this._maxListItemEntries, this._scrollRect);
}
}
[PlatformSupport.IL2CPP.Preserve]
sealed class DateTimeData
{
#pragma warning disable 0649
[PlatformSupport.IL2CPP.Preserve]
public int eventid;
[PlatformSupport.IL2CPP.Preserve]
public string datetime;
#pragma warning restore
public override string ToString()
{
return string.Format("[DateTimeData EventId: {0}, DateTime: {1}]", this.eventid, this.datetime);
}
}
}
#endif