...

Author: zamgi

m3u8.client/Properties/AssemblyInfo.cs

@@ -1,9 +1,6 @@
 using System.Reflection;
 using System.Runtime.InteropServices;
 
-// General Information about an assembly is controlled through the following 
-// set of attributes. Change these attribute values to modify the information
-// associated with an assembly.
 [assembly: AssemblyTitle("m3u8.client")]
 [assembly: AssemblyDescription("")]
 [assembly: AssemblyConfiguration("")]
@@ -12,12 +9,6 @@
 [assembly: AssemblyCopyright("Copyright © zamgi 2018")]
 [assembly: AssemblyTrademark("")]
 [assembly: AssemblyCulture("")]
-
-// Setting ComVisible to false makes the types in this assembly not visible 
-// to COM components.  If you need to access a type in this assembly from 
-// COM, set the ComVisible attribute to true on that type.
 [assembly: ComVisible(false)]
-
-// The following GUID is for the ID of the typelib if this project is exposed to COM
 [assembly: Guid("46961224-7b51-4115-ba59-53f8537cf7c4")]
 

m3u8.client/download_threads_semaphore.cs

@@ -1,5 +1,6 @@
 using System;
 using System.Threading;
+using System.Threading.Tasks;
 
 namespace m3u8
 {
@@ -11,6 +12,7 @@ internal interface I_download_threads_semaphore : IDisposable
         bool UseCrossDownloadInstanceParallelism { get; }
 
         void Wait( CancellationToken ct );
+        Task WaitAsync( CancellationToken ct );
         void Release();
     }
 }

m3u8.client/m3u8.client.cs

@@ -466,11 +466,6 @@ private HttpRequestMessage CreateRequstGet( Uri url )
             throw (new m3u8_Exception( $"No content found while {_AttemptRequestCount} attempt requests." ));
         }
 
-        //public async Task< m3u8_file_t__v2 > DownloadFile__v2( Uri url, CancellationToken ct = default )
-        //{
-        //    var mf = await DownloadFile( url, ct ).CAX();
-        //    return (m3u8_file_t__v2.Parse( mf ));
-        //}
         public async Task< m3u8_part_ts__v2 > DownloadPart__v2( m3u8_part_ts__v2 part, Uri baseAddress, CancellationToken ct = default )
         {
             if ( baseAddress == null )                       throw (new m3u8_ArgumentException( nameof(baseAddress) ));

m3u8.client/m3u8.client.csproj

@@ -44,6 +44,7 @@
     <Compile Include="m3u8_processor.cs" />
     <Compile Include="m3u8_processor_adv.cs" />
     <Compile Include="m3u8_processor_adv__v2.cs" />
+    <Compile Include="m3u8_processor_next.cs" />
     <Compile Include="m3u8_processor__v2.cs" />
     <Compile Include="obj_pool.cs" />
     <Compile Include="Properties\AssemblyInfo.cs" />

m3u8.client/m3u8.client.factory.cs

@@ -288,11 +288,11 @@ static void set_Protocol( SslClientAuthenticationOptions sslOptions, SslProtocol
                 return (h);
             };
 
-            var handler = CreateSocketsHttpHandler( in timeout );
+            var handler    = CreateSocketsHttpHandler( in timeout );
             var httpClient = new HttpClient( handler, true );
 #else
             var httpClient = new HttpClient();
-#endif            
+#endif
             if ( timeout.HasValue )
             {
                 httpClient.Timeout = timeout.Value;

m3u8.client/m3u8_processor_adv__v2.cs

@@ -130,7 +130,7 @@ private static IEnumerable< m3u8_part_ts__v2 > download_m3u8File_parts_parallel(
                 for ( var localReadyParts = new Queue< m3u8_part_ts__v2 >( Math.Min( 0x1000, ip.MaxDegreeOfParallelism ) );
                           expectedPartNumber <= maxPartNumber; )
                 {
-                    var idx = WaitHandle.WaitAny( new[] { canExtractPartEvent /*0*/, /*ct*/ joinedCts.Token.WaitHandle /*1*/, } );
+                    var idx = WaitHandle.WaitAny( [canExtractPartEvent /*0*/, /*ct*/ joinedCts.Token.WaitHandle /*1*/] );
                     if ( idx == 1 ) //[ct.IsCancellationRequested := 1]
                         break;
                     if ( idx != 0 ) //[canExtractPartEvent := 0]