Permalink
Browse files

fixed up and using more observers

  • Loading branch information...
1 parent 375400c commit 152ac325de8461c0617daed485ae0a38a8fc5695 @jhollingworth committed Jan 18, 2011
Showing with 242 additions and 69 deletions.
  1. +4 −9 TweetSharp.Rx/TweetSharp.Rx.Console/Program.cs
  2. +6 −2 TweetSharp.Rx/TweetSharp.Rx.Console/TweetSharp.Rx.Console.csproj
  3. BIN TweetSharp.Rx/TweetSharp.Rx.Console/obj/x86/Debug/DesignTimeResolveAssemblyReferencesInput.cache
  4. BIN TweetSharp.Rx/TweetSharp.Rx.Console/obj/x86/Debug/GenerateResource.read.1.tlog
  5. BIN TweetSharp.Rx/TweetSharp.Rx.Console/obj/x86/Debug/GenerateResource.write.1.tlog
  6. BIN TweetSharp.Rx/TweetSharp.Rx.Console/obj/x86/Debug/ResolveAssemblyReference.cache
  7. +20 −0 TweetSharp.Rx/TweetSharp.Rx.Console/obj/x86/Debug/TweetSharp.Rx.Console.csproj.FileListAbsolute.txt
  8. BIN TweetSharp.Rx/TweetSharp.Rx.Console/obj/x86/Debug/TweetSharp.Rx.Console.exe
  9. BIN TweetSharp.Rx/TweetSharp.Rx.Console/obj/x86/Debug/TweetSharp.Rx.Console.pdb
  10. BIN TweetSharp.Rx/TweetSharp.Rx.Specs/obj/Debug/DesignTimeResolveAssemblyReferencesInput.cache
  11. BIN TweetSharp.Rx/TweetSharp.Rx.Specs/obj/Debug/GenerateResource.read.1.tlog
  12. BIN TweetSharp.Rx/TweetSharp.Rx.Specs/obj/Debug/GenerateResource.write.1.tlog
  13. BIN TweetSharp.Rx/TweetSharp.Rx.Specs/obj/Debug/ResolveAssemblyReference.cache
  14. +9 −0 TweetSharp.Rx/TweetSharp.Rx.Specs/obj/Debug/TweetSharp.Rx.Specs.csproj.FileListAbsolute.txt
  15. BIN TweetSharp.Rx/TweetSharp.Rx.Specs/obj/Debug/TweetSharp.Rx.Specs.dll
  16. BIN TweetSharp.Rx/TweetSharp.Rx.Specs/obj/Debug/TweetSharp.Rx.Specs.pdb
  17. +11 −0 TweetSharp.Rx/TweetSharp.Rx/Entities/DeleteTweet.cs
  18. +1 −1 TweetSharp.Rx/TweetSharp.Rx/Entities/Friends.cs
  19. +1 −1 TweetSharp.Rx/TweetSharp.Rx/IUserStreamObservable.cs
  20. +3 −3 TweetSharp.Rx/TweetSharp.Rx/MessageProcessors/DeleteMessageProcessor.cs
  21. +8 −1 TweetSharp.Rx/TweetSharp.Rx/TweetSharp.Rx.csproj
  22. +48 −0 TweetSharp.Rx/TweetSharp.Rx/UserMessageStreamObservable .cs
  23. +22 −42 TweetSharp.Rx/TweetSharp.Rx/UserStreamObservable.cs
  24. BIN TweetSharp.Rx/TweetSharp.Rx/obj/Debug/DesignTimeResolveAssemblyReferencesInput.cache
  25. BIN TweetSharp.Rx/TweetSharp.Rx/obj/Debug/ResolveAssemblyReference.cache
  26. +14 −0 TweetSharp.Rx/TweetSharp.Rx/obj/Debug/TweetSharp.Rx.csproj.FileListAbsolute.txt
  27. BIN TweetSharp.Rx/TweetSharp.Rx/obj/Debug/TweetSharp.Rx.dll
  28. BIN TweetSharp.Rx/TweetSharp.Rx/obj/Debug/TweetSharp.Rx.pdb
  29. +1 −1 TweetSharp.Rx/_ReSharper.TweetSharp.Rx/BuildScriptCache/.crc
  30. BIN TweetSharp.Rx/_ReSharper.TweetSharp.Rx/BuildScriptCache/2/6bc591a0.dat
  31. +1 −0 ...p.Rx/_ReSharper.TweetSharp.Rx/DecompilerCache/metadata/System.Reactive-1511/Assembly.Location.txt
  32. +21 −0 ...harper.TweetSharp.Rx/DecompilerCache/metadata/System.Reactive-1511/System.ObservableExtensions.cs
  33. +51 −0 ....TweetSharp.Rx/DecompilerCache/metadata/System.Reactive-1511/System.ObservableExtensions.cs.flags
  34. +15 −0 ...r.TweetSharp.Rx/DecompilerCache/metadata/System.Reactive-1511/System.ObservableExtensions.cs.info
  35. +2 −5 TweetSharp.Rx/_ReSharper.TweetSharp.Rx/ModuleIds.xml
  36. +1 −1 TweetSharp.Rx/_ReSharper.TweetSharp.Rx/NamedArguments/.crc
  37. BIN TweetSharp.Rx/_ReSharper.TweetSharp.Rx/NamedArguments/2/6bc591a0.dat
  38. BIN TweetSharp.Rx/_ReSharper.TweetSharp.Rx/PdbInfo/5bafe43f920a1a1987a99b81ecfee8ac32dd4677
  39. BIN TweetSharp.Rx/_ReSharper.TweetSharp.Rx/PdbInfo/ee94c972fd8191ce7181c4f5709f26f17f3b2add
  40. +1 −1 TweetSharp.Rx/_ReSharper.TweetSharp.Rx/Resources/.crc
  41. BIN TweetSharp.Rx/_ReSharper.TweetSharp.Rx/Resources/4/780e8c46.dat
  42. BIN TweetSharp.Rx/_ReSharper.TweetSharp.Rx/SymbolCache.bin
  43. +1 −1 TweetSharp.Rx/_ReSharper.TweetSharp.Rx/TodoCache/.crc
  44. BIN TweetSharp.Rx/_ReSharper.TweetSharp.Rx/TodoCache/1/1f22b012.dat
  45. +1 −1 TweetSharp.Rx/_ReSharper.TweetSharp.Rx/WordIndex/.crc
  46. BIN TweetSharp.Rx/_ReSharper.TweetSharp.Rx/WordIndex/3/2da4de91.dat
@@ -1,5 +1,4 @@
using System;
-using System.Linq;
using TweetSharp.Rx.Entities;
using TweetSharp.Twitter.Fluent;
using TweetSharp.Twitter.Model;
@@ -16,18 +15,14 @@ static void Main()
.FromUser()
.ToObservable();
- var statusSubscriber = twitter
- .Where<TwitterStatus>(s => s.Text != "FOo")
- .Subscribe(status => System.Console.WriteLine(status.Text));
+ twitter.Subscribe<TwitterStatus>(s => System.Console.WriteLine("Status: " + s.Text));
+
+ twitter.Subscribe<Friends>(s => System.Console.WriteLine("Friend Ids: " + s.FriendIds));
- var deleteSubscriber = twitter.Subscribe<Delete>(System.Console.WriteLine);
+ twitter.Subscribe<DeleteTweet>(s => System.Console.WriteLine("Tweet Deleted: " + s.RawSource));
System.Console.WriteLine("Press enter to quit");
System.Console.ReadKey();
-
- statusSubscriber.Dispose();
- deleteSubscriber.Dispose();
-
System.Console.WriteLine("Goodbye!");
}
}
@@ -51,8 +51,12 @@
<Reference Include="Microsoft.CSharp" />
<Reference Include="System.Data" />
<Reference Include="System.Xml" />
- <Reference Include="TweetSharp, Version=1.0.0.0, Culture=neutral, PublicKeyToken=c148cfba29ed1a4d, processorArchitecture=MSIL" />
- <Reference Include="TweetSharp.Twitter, Version=1.0.0.0, Culture=neutral, PublicKeyToken=c148cfba29ed1a4d, processorArchitecture=MSIL" />
+ <Reference Include="TweetSharp">
+ <HintPath>..\lib\TweetSharp.dll</HintPath>
+ </Reference>
+ <Reference Include="TweetSharp.Twitter">
+ <HintPath>..\lib\TweetSharp.Twitter.dll</HintPath>
+ </Reference>
</ItemGroup>
<ItemGroup>
<Compile Include="Program.cs" />
@@ -16,3 +16,23 @@ C:\src\TweetSharp.Rx\TweetSharp.Rx.Console\bin\Debug\TweetSharp.Twitter.xml
C:\src\TweetSharp.Rx\TweetSharp.Rx.Console\bin\Debug\TweetSharp.xml
C:\src\TweetSharp.Rx\TweetSharp.Rx.Console\bin\Debug\TweetSharp.Rx.dll
C:\src\TweetSharp.Rx\TweetSharp.Rx.Console\bin\Debug\TweetSharp.Rx.pdb
+C:\src\Personal\TweetSharp.Rx\TweetSharp.Rx\TweetSharp.Rx.Console\bin\Debug\TweetSharp.Rx.Console.exe.config
+C:\src\Personal\TweetSharp.Rx\TweetSharp.Rx\TweetSharp.Rx.Console\obj\x86\Debug\TweetSharp.Rx.Console.exe
+C:\src\Personal\TweetSharp.Rx\TweetSharp.Rx\TweetSharp.Rx.Console\obj\x86\Debug\TweetSharp.Rx.Console.pdb
+C:\src\Personal\TweetSharp.Rx\TweetSharp.Rx\TweetSharp.Rx.Console\obj\x86\Debug\ResolveAssemblyReference.cache
+C:\src\Personal\TweetSharp.Rx\TweetSharp.Rx\TweetSharp.Rx.Console\obj\x86\Debug\TweetSharp.Rx.Console.Settings.resources
+C:\src\Personal\TweetSharp.Rx\TweetSharp.Rx\TweetSharp.Rx.Console\obj\x86\Debug\GenerateResource.read.1.tlog
+C:\src\Personal\TweetSharp.Rx\TweetSharp.Rx\TweetSharp.Rx.Console\obj\x86\Debug\GenerateResource.write.1.tlog
+C:\src\Personal\TweetSharp.Rx\TweetSharp.Rx\TweetSharp.Rx.Console\bin\Debug\TweetSharp.Rx.Console.exe
+C:\src\Personal\TweetSharp.Rx\TweetSharp.Rx\TweetSharp.Rx.Console\bin\Debug\TweetSharp.Rx.Console.pdb
+C:\src\Personal\TweetSharp.Rx\TweetSharp.Rx\TweetSharp.Rx.Console\bin\Debug\System.CoreEx.dll
+C:\src\Personal\TweetSharp.Rx\TweetSharp.Rx\TweetSharp.Rx.Console\bin\Debug\System.Reactive.dll
+C:\src\Personal\TweetSharp.Rx\TweetSharp.Rx\TweetSharp.Rx.Console\bin\Debug\TweetSharp.dll
+C:\src\Personal\TweetSharp.Rx\TweetSharp.Rx\TweetSharp.Rx.Console\bin\Debug\TweetSharp.Rx.dll
+C:\src\Personal\TweetSharp.Rx\TweetSharp.Rx\TweetSharp.Rx.Console\bin\Debug\TweetSharp.Twitter.dll
+C:\src\Personal\TweetSharp.Rx\TweetSharp.Rx\TweetSharp.Rx.Console\bin\Debug\Newtonsoft.Json.dll
+C:\src\Personal\TweetSharp.Rx\TweetSharp.Rx\TweetSharp.Rx.Console\bin\Debug\Hammock.dll
+C:\src\Personal\TweetSharp.Rx\TweetSharp.Rx\TweetSharp.Rx.Console\bin\Debug\TweetSharp.Rx.pdb
+C:\src\Personal\TweetSharp.Rx\TweetSharp.Rx\TweetSharp.Rx.Console\bin\Debug\TweetSharp.pdb
+C:\src\Personal\TweetSharp.Rx\TweetSharp.Rx\TweetSharp.Rx.Console\bin\Debug\TweetSharp.Twitter.pdb
+C:\src\Personal\TweetSharp.Rx\TweetSharp.Rx\TweetSharp.Rx.Console\bin\Debug\Hammock.pdb
@@ -7,3 +7,12 @@ C:\src\TweetSharp.Rx\TweetSharp.Rx.Specs\obj\Debug\GenerateResource.read.1.tlog
C:\src\TweetSharp.Rx\TweetSharp.Rx.Specs\obj\Debug\GenerateResource.write.1.tlog
C:\src\TweetSharp.Rx\TweetSharp.Rx.Specs\obj\Debug\TweetSharp.Rx.Specs.dll
C:\src\TweetSharp.Rx\TweetSharp.Rx.Specs\obj\Debug\TweetSharp.Rx.Specs.pdb
+C:\src\Personal\TweetSharp.Rx\TweetSharp.Rx\TweetSharp.Rx.Specs\bin\Debug\TweetSharp.Rx.Specs.dll
+C:\src\Personal\TweetSharp.Rx\TweetSharp.Rx\TweetSharp.Rx.Specs\bin\Debug\TweetSharp.Rx.Specs.pdb
+C:\src\Personal\TweetSharp.Rx\TweetSharp.Rx\TweetSharp.Rx.Specs\bin\Debug\Machine.Specifications.dll
+C:\src\Personal\TweetSharp.Rx\TweetSharp.Rx\TweetSharp.Rx.Specs\obj\Debug\ResolveAssemblyReference.cache
+C:\src\Personal\TweetSharp.Rx\TweetSharp.Rx\TweetSharp.Rx.Specs\obj\Debug\TweetSharp.Rx.Specs.Settings.resources
+C:\src\Personal\TweetSharp.Rx\TweetSharp.Rx\TweetSharp.Rx.Specs\obj\Debug\GenerateResource.read.1.tlog
+C:\src\Personal\TweetSharp.Rx\TweetSharp.Rx\TweetSharp.Rx.Specs\obj\Debug\GenerateResource.write.1.tlog
+C:\src\Personal\TweetSharp.Rx\TweetSharp.Rx\TweetSharp.Rx.Specs\obj\Debug\TweetSharp.Rx.Specs.dll
+C:\src\Personal\TweetSharp.Rx\TweetSharp.Rx\TweetSharp.Rx.Specs\obj\Debug\TweetSharp.Rx.Specs.pdb
@@ -0,0 +1,11 @@
+using System;
+using TweetSharp.Model;
+using TweetSharp.Twitter.Model;
+
+namespace TweetSharp.Rx.Entities
+{
+ public class DeleteTweet : ITwitterModel
+ {
+ public string RawSource { get; set; }
+ }
+}
@@ -3,7 +3,7 @@
namespace TweetSharp.Rx.Entities
{
- internal class Friends : ITwitterModel
+ public class Friends : ITwitterModel
{
public string FriendIds { get; set; }
@@ -4,7 +4,7 @@
namespace TweetSharp.Rx
{
- public interface IUserStreamObservable : IObservable<TwitterStatus>, IObservable<Delete>
+ public interface IUserStreamObservable : IObservable<TwitterStatus>, IObservable<DeleteTweet>, IObservable<Friends>
{
}
}
@@ -4,7 +4,7 @@
namespace TweetSharp.Rx.MessageProcessors
{
- internal class DeleteMessageProcessor : IMessageProcessor<Delete>
+ internal class DeleteMessageProcessor : IMessageProcessor<DeleteTweet>
{
private readonly Regex _regex = new Regex("^{\\\"delete\\\":");
@@ -13,9 +13,9 @@ public Regex MessageRegex
get { return _regex; }
}
- public Delete Process(TwitterResult result)
+ public DeleteTweet Process(TwitterResult result)
{
- return new Delete {RawSource = result.Response};
+ return new DeleteTweet {RawSource = result.Response};
}
}
}
@@ -37,6 +37,12 @@
</Reference>
<Reference Include="System" />
<Reference Include="System.Core" />
+ <Reference Include="System.CoreEx">
+ <HintPath>..\lib\System.CoreEx.dll</HintPath>
+ </Reference>
+ <Reference Include="System.Reactive">
+ <HintPath>..\lib\System.Reactive.dll</HintPath>
+ </Reference>
<Reference Include="System.Xml.Linq" />
<Reference Include="System.Data.DataSetExtensions" />
<Reference Include="Microsoft.CSharp" />
@@ -53,7 +59,7 @@
</ItemGroup>
<ItemGroup>
<Compile Include="ActionDisposable.cs" />
- <Compile Include="Entities\Delete.cs" />
+ <Compile Include="Entities\DeleteTweet.cs" />
<Compile Include="ITwitterStreamingUserExtensions.cs" />
<Compile Include="IUserStreamObservable.cs" />
<Compile Include="Entities\Friends.cs" />
@@ -63,6 +69,7 @@
<Compile Include="MessageProcessors\StatusMessageProcessor.cs" />
<Compile Include="Properties\AssemblyInfo.cs" />
<Compile Include="IUserStreamEvent.cs" />
+ <Compile Include="UserMessageStreamObservable .cs" />
<Compile Include="UserStreamObservable.cs" />
</ItemGroup>
<Import Project="$(MSBuildToolsPath)\Microsoft.CSharp.targets" />
@@ -0,0 +1,48 @@
+using System;
+using System.Collections.Generic;
+using TweetSharp.Twitter.Fluent;
+using TweetSharp.Twitter.Model;
+
+namespace TweetSharp.Rx
+{
+ internal class UserMessageStreamObservable : IObservable<TwitterResult>
+ {
+ private readonly List<IObserver<TwitterResult>> _observers = new List<IObserver<TwitterResult>>();
+
+ public UserMessageStreamObservable(ITwitterStreamingUser userStream)
+ {
+ userStream.Take(1).CallbackTo(MessageRecieved).BeginRequest();
+ }
+
+ private void MessageRecieved(object sender, TwitterResult result, object userstate)
+ {
+ result.Response = result.Response.Trim();
+
+ lock(_observers)
+ {
+ foreach (var observer in _observers)
+ {
+ observer.OnNext(result);
+ }
+ }
+ }
+
+ public IDisposable Subscribe(IObserver<TwitterResult> observer)
+ {
+ _observers.Add(observer);
+
+ return new ActionDisposable(() => Remove(observer));
+ }
+
+ private void Remove(IObserver<TwitterResult> observer)
+ {
+ lock(_observers)
+ {
+ if(_observers.Contains(observer))
+ {
+ _observers.Remove(observer);
+ }
+ }
+ }
+ }
+}
@@ -1,5 +1,4 @@
using System;
-using System.Collections.Generic;
using System.Linq;
using TweetSharp.Rx.Entities;
using TweetSharp.Rx.MessageProcessors;
@@ -10,65 +9,46 @@ namespace TweetSharp.Rx
{
public class UserStreamObservable : IUserStreamObservable
{
- private readonly List<IMessageProcessor<ITwitterModel>> _processors = new List<IMessageProcessor<ITwitterModel>>();
+ private readonly IObservable<TwitterResult> _messageStream;
+ private readonly IObservable<TwitterStatus> _statusObservable;
+ private readonly IObservable<DeleteTweet> _deleteObservable;
+ private readonly IObservable<Friends> _friendsObservable;
- private readonly Dictionary<Type, List<IObservable<ITwitterModel>>> _observers = new Dictionary<Type, List<IObservable<ITwitterModel>>>();
public UserStreamObservable(ITwitterStreamingUser userStream)
{
- userStream.Take(1).CallbackTo(MessageRecieved).BeginRequest();
+ _messageStream = new UserMessageStreamObservable(userStream);
- _processors.Add((IMessageProcessor<ITwitterModel>) new FriendMessageProcessor());
- _processors.Add((IMessageProcessor<ITwitterModel>) new StatusMessageProcessor());
- _processors.Add((IMessageProcessor<ITwitterModel>) new DeleteMessageProcessor());
+ var statusProcessor = new StatusMessageProcessor();
+ var deleteProcessor = new DeleteMessageProcessor();
+ var friendProcessor = new FriendMessageProcessor();
- foreach (var processor in _processors)
- {
- _observers.Add(processor.GetType(), new List<IObservable<ITwitterModel>>());
- }
- }
-
- private void MessageRecieved(object sender, TwitterResult result, object userstate)
- {
- var response = result.Response.Trim();
- foreach (var processor in _processors)
- {
- if (processor.MessageRegex.IsMatch(response))
- {
- processor.Process(result);
- break;
- }
- }
+ _statusObservable = _messageStream
+ .Where(s => statusProcessor.MessageRegex.IsMatch(s.Response))
+ .Select(statusProcessor.Process);
- //var observers = _observers.ToArray();
+ _deleteObservable = _messageStream
+ .Where(s => deleteProcessor.MessageRegex.IsMatch(s.Response))
+ .Select(deleteProcessor.Process);
- //foreach (var observer in observers)
- //{
- // observer.OnNext(result.Response);
- //}
+ _friendsObservable = _messageStream
+ .Where(s => friendProcessor.MessageRegex.IsMatch(s.Response))
+ .Select(friendProcessor.Process);
}
public IDisposable Subscribe(IObserver<TwitterStatus> observer)
{
- //_statusObservers.Add(observer);
-
- //return new ActionDisposable(() => _statusObservers.Remove(observer));
-
- return null;
+ return _statusObservable.Subscribe(observer);
}
- private IDisposable AddObserver<T>(IObserver<T> observer)
+ public IDisposable Subscribe(IObserver<DeleteTweet> observer)
{
- return null;
+ return _deleteObservable.Subscribe(observer);
}
- public IDisposable Subscribe(IObserver<Delete> observer)
+ public IDisposable Subscribe(IObserver<Friends> observer)
{
- //_deleteObservers.Add(observer);
-
- //return new ActionDisposable(() => _deleteObservers.Remove(observer));
- return null;
-
+ return _friendsObservable.Subscribe(observer);
}
}
}
@@ -10,3 +10,17 @@ C:\src\TweetSharp.Rx\TweetSharp.Rx\obj\Debug\TweetSharp.Rx.pdb
C:\src\TweetSharp.Rx\TweetSharp.Rx\bin\Debug\Hammock.pdb
C:\src\TweetSharp.Rx\TweetSharp.Rx\bin\Debug\TweetSharp.dll
C:\src\TweetSharp.Rx\TweetSharp.Rx\bin\Debug\TweetSharp.Twitter.dll
+C:\src\Personal\TweetSharp.Rx\TweetSharp.Rx\TweetSharp.Rx\obj\Debug\ResolveAssemblyReference.cache
+C:\src\Personal\TweetSharp.Rx\TweetSharp.Rx\TweetSharp.Rx\obj\Debug\TweetSharp.Rx.dll
+C:\src\Personal\TweetSharp.Rx\TweetSharp.Rx\TweetSharp.Rx\bin\Debug\TweetSharp.Rx.dll
+C:\src\Personal\TweetSharp.Rx\TweetSharp.Rx\TweetSharp.Rx\bin\Debug\TweetSharp.Rx.pdb
+C:\src\Personal\TweetSharp.Rx\TweetSharp.Rx\TweetSharp.Rx\bin\Debug\Newtonsoft.Json.dll
+C:\src\Personal\TweetSharp.Rx\TweetSharp.Rx\TweetSharp.Rx\bin\Debug\System.CoreEx.dll
+C:\src\Personal\TweetSharp.Rx\TweetSharp.Rx\TweetSharp.Rx\bin\Debug\System.Reactive.dll
+C:\src\Personal\TweetSharp.Rx\TweetSharp.Rx\TweetSharp.Rx\bin\Debug\TweetSharp.dll
+C:\src\Personal\TweetSharp.Rx\TweetSharp.Rx\TweetSharp.Rx\bin\Debug\TweetSharp.Twitter.dll
+C:\src\Personal\TweetSharp.Rx\TweetSharp.Rx\TweetSharp.Rx\bin\Debug\Hammock.dll
+C:\src\Personal\TweetSharp.Rx\TweetSharp.Rx\TweetSharp.Rx\bin\Debug\TweetSharp.pdb
+C:\src\Personal\TweetSharp.Rx\TweetSharp.Rx\TweetSharp.Rx\bin\Debug\TweetSharp.Twitter.pdb
+C:\src\Personal\TweetSharp.Rx\TweetSharp.Rx\TweetSharp.Rx\bin\Debug\Hammock.pdb
+C:\src\Personal\TweetSharp.Rx\TweetSharp.Rx\TweetSharp.Rx\obj\Debug\TweetSharp.Rx.pdb
Binary file not shown.
Binary file not shown.
@@ -1 +1 @@
-�z
+�W�V
@@ -0,0 +1 @@
+C:\src\Personal\TweetSharp.Rx\TweetSharp.Rx\lib\System.Reactive.dll
@@ -0,0 +1,21 @@
+// Type: System.ObservableExtensions
+// Assembly: System.Reactive, Version=1.0.2838.104, Culture=neutral, PublicKeyToken=31bf3856ad364e35
+// Assembly location: C:\src\Personal\TweetSharp.Rx\TweetSharp.Rx\lib\System.Reactive.dll
+
+namespace System
+{
+ public static class ObservableExtensions
+ {
+ public static IDisposable Subscribe<TSource>(this IObservable<TSource> source);
+ public static IDisposable Subscribe<TSource>(this IObservable<TSource> source, Action<TSource> onNext);
+
+ public static IDisposable Subscribe<TSource>(this IObservable<TSource> source, Action<TSource> onNext,
+ Action<Exception> onError);
+
+ public static IDisposable Subscribe<TSource>(this IObservable<TSource> source, Action<TSource> onNext,
+ Action onCompleted);
+
+ public static IDisposable Subscribe<TSource>(this IObservable<TSource> source, Action<TSource> onNext,
+ Action<Exception> onError, Action onCompleted);
+ }
+}
Oops, something went wrong.

0 comments on commit 152ac32

Please sign in to comment.